fix: Generate Azure date.time as Timestamps (#1885)

erezrokah · web-flow · commit 92d41a1df754 · 2022-09-21T07:51:16.000Z
#### Summary Depends on cloudquery/plugin-sdk#139. Fixes #1826 ---
diff --git a/plugins/source/azure/resources/services/compute/disks.go b/plugins/source/azure/resources/services/compute/disks.go
@@ -47,7 +47,7 @@ func Disks() *schema.Table {
 			},
 			{
 				Name:     "time_created",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("TimeCreated"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/container/registries.go b/plugins/source/azure/resources/services/container/registries.go
@@ -32,7 +32,7 @@ func Registries() *schema.Table {
 			},
 			{
 				Name:     "creation_date",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("CreationDate"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/datalake/analytics_accounts.go b/plugins/source/azure/resources/services/datalake/analytics_accounts.go
@@ -115,12 +115,12 @@ func AnalyticsAccounts() *schema.Table {
 			},
 			{
 				Name:     "creation_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("CreationTime"),
 			},
 			{
 				Name:     "last_modified_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("LastModifiedTime"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/datalake/store_accounts.go b/plugins/source/azure/resources/services/datalake/store_accounts.go
@@ -100,12 +100,12 @@ func StoreAccounts() *schema.Table {
 			},
 			{
 				Name:     "creation_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("CreationTime"),
 			},
 			{
 				Name:     "last_modified_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("LastModifiedTime"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/eventhub/namespaces.go b/plugins/source/azure/resources/services/eventhub/namespaces.go
@@ -37,12 +37,12 @@ func Namespaces() *schema.Table {
 			},
 			{
 				Name:     "created_at",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("CreatedAt"),
 			},
 			{
 				Name:     "updated_at",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("UpdatedAt"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/logic/workflows.go b/plugins/source/azure/resources/services/logic/workflows.go
@@ -27,12 +27,12 @@ func Workflows() *schema.Table {
 			},
 			{
 				Name:     "created_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("CreatedTime"),
 			},
 			{
 				Name:     "changed_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("ChangedTime"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/mariadb/servers.go b/plugins/source/azure/resources/services/mariadb/servers.go
@@ -52,7 +52,7 @@ func Servers() *schema.Table {
 			},
 			{
 				Name:     "earliest_restore_date",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("EarliestRestoreDate"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/monitor/activity_logs.go b/plugins/source/azure/resources/services/monitor/activity_logs.go
@@ -127,12 +127,12 @@ func ActivityLogs() *schema.Table {
 			},
 			{
 				Name:     "event_timestamp",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("EventTimestamp"),
 			},
 			{
 				Name:     "submission_timestamp",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("SubmissionTimestamp"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/mysql/servers.go b/plugins/source/azure/resources/services/mysql/servers.go
@@ -72,7 +72,7 @@ func Servers() *schema.Table {
 			},
 			{
 				Name:     "earliest_restore_date",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("EarliestRestoreDate"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/postgresql/servers.go b/plugins/source/azure/resources/services/postgresql/servers.go
@@ -72,7 +72,7 @@ func Servers() *schema.Table {
 			},
 			{
 				Name:     "earliest_restore_date",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("EarliestRestoreDate"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/servicebus/namespaces.go b/plugins/source/azure/resources/services/servicebus/namespaces.go
@@ -47,12 +47,12 @@ func Namespaces() *schema.Table {
 			},
 			{
 				Name:     "created_at",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("CreatedAt"),
 			},
 			{
 				Name:     "updated_at",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("UpdatedAt"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/servicebus/topics.go b/plugins/source/azure/resources/services/servicebus/topics.go
@@ -33,17 +33,17 @@ func topics() *schema.Table {
 			},
 			{
 				Name:     "created_at",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("CreatedAt"),
 			},
 			{
 				Name:     "updated_at",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("UpdatedAt"),
 			},
 			{
 				Name:     "accessed_at",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("AccessedAt"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/sql/database_vulnerability_assessment_scans.go b/plugins/source/azure/resources/services/sql/database_vulnerability_assessment_scans.go
@@ -43,12 +43,12 @@ func databaseVulnerabilityAssessmentScans() *schema.Table {
 			},
 			{
 				Name:     "start_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("StartTime"),
 			},
 			{
 				Name:     "end_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("EndTime"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/sql/databases.go b/plugins/source/azure/resources/services/sql/databases.go
@@ -78,7 +78,7 @@ func databases() *schema.Table {
 			},
 			{
 				Name:     "creation_date",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("CreationDate"),
 			},
 			{
@@ -103,12 +103,12 @@ func databases() *schema.Table {
 			},
 			{
 				Name:     "restore_point_in_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("RestorePointInTime"),
 			},
 			{
 				Name:     "source_database_deletion_date",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("SourceDatabaseDeletionDate"),
 			},
 			{
@@ -153,7 +153,7 @@ func databases() *schema.Table {
 			},
 			{
 				Name:     "earliest_restore_date",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("EarliestRestoreDate"),
 			},
 			{
@@ -193,12 +193,12 @@ func databases() *schema.Table {
 			},
 			{
 				Name:     "paused_date",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("PausedDate"),
 			},
 			{
 				Name:     "resumed_date",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("ResumedDate"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/sql/managed_database_vulnerability_assessment_scans.go b/plugins/source/azure/resources/services/sql/managed_database_vulnerability_assessment_scans.go
@@ -43,12 +43,12 @@ func managedDatabaseVulnerabilityAssessmentScans() *schema.Table {
 			},
 			{
 				Name:     "start_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("StartTime"),
 			},
 			{
 				Name:     "end_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("EndTime"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/sql/managed_databases.go b/plugins/source/azure/resources/services/sql/managed_databases.go
@@ -38,17 +38,17 @@ func managedDatabases() *schema.Table {
 			},
 			{
 				Name:     "creation_date",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("CreationDate"),
 			},
 			{
 				Name:     "earliest_restore_point",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("EarliestRestorePoint"),
 			},
 			{
 				Name:     "restore_point_in_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("RestorePointInTime"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/sql/managed_instances.go b/plugins/source/azure/resources/services/sql/managed_instances.go
@@ -107,7 +107,7 @@ func ManagedInstances() *schema.Table {
 			},
 			{
 				Name:     "restore_point_in_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("RestorePointInTime"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/sql/server_security_alert_policies.go b/plugins/source/azure/resources/services/sql/server_security_alert_policies.go
@@ -63,7 +63,7 @@ func serverSecurityAlertPolicies() *schema.Table {
 			},
 			{
 				Name:     "creation_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("CreationTime"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/storage/accounts.go b/plugins/source/azure/resources/services/storage/accounts.go
@@ -64,7 +64,7 @@ func Accounts() *schema.Table {
 			},
 			{
 				Name:     "last_geo_failover_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("LastGeoFailoverTime"),
 			},
 			{
@@ -79,7 +79,7 @@ func Accounts() *schema.Table {
 			},
 			{
 				Name:     "creation_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("CreationTime"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/storage/containers.go b/plugins/source/azure/resources/services/storage/containers.go
@@ -38,7 +38,7 @@ func containers() *schema.Table {
 			},
 			{
 				Name:     "deleted_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("DeletedTime"),
 			},
 			{
@@ -63,7 +63,7 @@ func containers() *schema.Table {
 			},
 			{
 				Name:     "last_modified_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("LastModifiedTime"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/streamanalytics/streaming_jobs.go b/plugins/source/azure/resources/services/streamanalytics/streaming_jobs.go
@@ -52,12 +52,12 @@ func StreamingJobs() *schema.Table {
 			},
 			{
 				Name:     "output_start_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("OutputStartTime"),
 			},
 			{
 				Name:     "last_output_event_time",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("LastOutputEventTime"),
 			},
 			{
@@ -92,7 +92,7 @@ func StreamingJobs() *schema.Table {
 			},
 			{
 				Name:     "created_date",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("CreatedDate"),
 			},
 			{
diff --git a/plugins/source/azure/resources/services/web/apps.go b/plugins/source/azure/resources/services/web/apps.go
@@ -82,7 +82,7 @@ func Apps() *schema.Table {
 			},
 			{
 				Name:     "last_modified_time_utc",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("LastModifiedTimeUtc"),
 			},
 			{
@@ -162,7 +162,7 @@ func Apps() *schema.Table {
 			},
 			{
 				Name:     "suspended_till",
-				Type:     schema.TypeJSON,
+				Type:     schema.TypeTimestamp,
 				Resolver: schema.PathResolver("SuspendedTill"),
 			},
 			{

Original file line number	Diff line number	Diff line change
`@@ -47,7 +47,7 @@ func Disks() *schema.Table {`
`47`	`47`	`},`
`48`	`48`	`{`
`49`	`49`	`Name: "time_created",`
`50`		`- Type: schema.TypeJSON,`
	`50`	`+ Type: schema.TypeTimestamp,`
`51`	`51`	`Resolver: schema.PathResolver("TimeCreated"),`
`52`	`52`	`},`
`53`	`53`	`{`
Original file line number	Diff line number	Diff line change
`@@ -32,7 +32,7 @@ func Registries() *schema.Table {`
`32`	`32`	`},`
`33`	`33`	`{`
`34`	`34`	`Name: "creation_date",`
`35`		`- Type: schema.TypeJSON,`
	`35`	`+ Type: schema.TypeTimestamp,`
`36`	`36`	`Resolver: schema.PathResolver("CreationDate"),`
`37`	`37`	`},`
`38`	`38`	`{`
Original file line number	Diff line number	Diff line change
`@@ -115,12 +115,12 @@ func AnalyticsAccounts() *schema.Table {`
`115`	`115`	`},`
`116`	`116`	`{`
`117`	`117`	`Name: "creation_time",`
`118`		`- Type: schema.TypeJSON,`
	`118`	`+ Type: schema.TypeTimestamp,`
`119`	`119`	`Resolver: schema.PathResolver("CreationTime"),`
`120`	`120`	`},`
`121`	`121`	`{`
`122`	`122`	`Name: "last_modified_time",`
`123`		`- Type: schema.TypeJSON,`
	`123`	`+ Type: schema.TypeTimestamp,`
`124`	`124`	`Resolver: schema.PathResolver("LastModifiedTime"),`
`125`	`125`	`},`
`126`	`126`	`{`
Original file line number	Diff line number	Diff line change
`@@ -100,12 +100,12 @@ func StoreAccounts() *schema.Table {`
`100`	`100`	`},`
`101`	`101`	`{`
`102`	`102`	`Name: "creation_time",`
`103`		`- Type: schema.TypeJSON,`
	`103`	`+ Type: schema.TypeTimestamp,`
`104`	`104`	`Resolver: schema.PathResolver("CreationTime"),`
`105`	`105`	`},`
`106`	`106`	`{`
`107`	`107`	`Name: "last_modified_time",`
`108`		`- Type: schema.TypeJSON,`
	`108`	`+ Type: schema.TypeTimestamp,`
`109`	`109`	`Resolver: schema.PathResolver("LastModifiedTime"),`
`110`	`110`	`},`
`111`	`111`	`{`
Original file line number	Diff line number	Diff line change
`@@ -37,12 +37,12 @@ func Namespaces() *schema.Table {`
`37`	`37`	`},`
`38`	`38`	`{`
`39`	`39`	`Name: "created_at",`
`40`		`- Type: schema.TypeJSON,`
	`40`	`+ Type: schema.TypeTimestamp,`
`41`	`41`	`Resolver: schema.PathResolver("CreatedAt"),`
`42`	`42`	`},`
`43`	`43`	`{`
`44`	`44`	`Name: "updated_at",`
`45`		`- Type: schema.TypeJSON,`
	`45`	`+ Type: schema.TypeTimestamp,`
`46`	`46`	`Resolver: schema.PathResolver("UpdatedAt"),`
`47`	`47`	`},`
`48`	`48`	`{`
Original file line number	Diff line number	Diff line change
`@@ -27,12 +27,12 @@ func Workflows() *schema.Table {`
`27`	`27`	`},`
`28`	`28`	`{`
`29`	`29`	`Name: "created_time",`
`30`		`- Type: schema.TypeJSON,`
	`30`	`+ Type: schema.TypeTimestamp,`
`31`	`31`	`Resolver: schema.PathResolver("CreatedTime"),`
`32`	`32`	`},`
`33`	`33`	`{`
`34`	`34`	`Name: "changed_time",`
`35`		`- Type: schema.TypeJSON,`
	`35`	`+ Type: schema.TypeTimestamp,`
`36`	`36`	`Resolver: schema.PathResolver("ChangedTime"),`
`37`	`37`	`},`
`38`	`38`	`{`
Original file line number	Diff line number	Diff line change
`@@ -52,7 +52,7 @@ func Servers() *schema.Table {`
`52`	`52`	`},`
`53`	`53`	`{`
`54`	`54`	`Name: "earliest_restore_date",`
`55`		`- Type: schema.TypeJSON,`
	`55`	`+ Type: schema.TypeTimestamp,`
`56`	`56`	`Resolver: schema.PathResolver("EarliestRestoreDate"),`
`57`	`57`	`},`
`58`	`58`	`{`
Original file line number	Diff line number	Diff line change
`@@ -127,12 +127,12 @@ func ActivityLogs() *schema.Table {`
`127`	`127`	`},`
`128`	`128`	`{`
`129`	`129`	`Name: "event_timestamp",`
`130`		`- Type: schema.TypeJSON,`
	`130`	`+ Type: schema.TypeTimestamp,`
`131`	`131`	`Resolver: schema.PathResolver("EventTimestamp"),`
`132`	`132`	`},`
`133`	`133`	`{`
`134`	`134`	`Name: "submission_timestamp",`
`135`		`- Type: schema.TypeJSON,`
	`135`	`+ Type: schema.TypeTimestamp,`
`136`	`136`	`Resolver: schema.PathResolver("SubmissionTimestamp"),`
`137`	`137`	`},`
`138`	`138`	`{`
Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,7 @@ func Servers() *schema.Table {`
`72`	`72`	`},`
`73`	`73`	`{`
`74`	`74`	`Name: "earliest_restore_date",`
`75`		`- Type: schema.TypeJSON,`
	`75`	`+ Type: schema.TypeTimestamp,`
`76`	`76`	`Resolver: schema.PathResolver("EarliestRestoreDate"),`
`77`	`77`	`},`
`78`	`78`	`{`