added created_at / updated_at

apps/extract-stack/src/extract-merge-requests.ts

@@ -62,6 +62,7 @@ export const eventHandler = EventHandler(extractRepositoryEvent, async (evt) =>
   const externalRepositoryId = evt.properties.repository.externalId;
   const repositoryName = evt.properties.repository.name;
   const namespace = evt.properties.namespace;
+  const repository = evt.properties.repository;
   const sourceControl = evt.metadata.sourceControl;
   const repositoryId = evt.properties.repository.id;
 
@@ -80,12 +81,8 @@ export const eventHandler = EventHandler(extractRepositoryEvent, async (evt) =>
   for (let index = 1; index <= paginationInfo.totalPages; index++) {
 
     await extractMergeRequestMessage.send({
-      repository: {
-        id: repositoryId,
-        externalId: externalRepositoryId,
-        name: repositoryName
-      },
-      namespace: namespace,
+      repository,
+      namespace,
       pagination: {
         page: index,
         perPage: paginationInfo.perPage,

migrations/extract/0001_wealthy_medusa.sql → migrations/extract/0000_purple_selene.sql

@@ -2,22 +2,26 @@ CREATE TABLE `members` (
 	`id` integer PRIMARY KEY NOT NULL,
 	`external_id` integer NOT NULL,
 	`name` text NOT NULL,
-	`username` text NOT NULL
+	`username` text NOT NULL,
+	`created_at` integer DEFAULT CURRENT_TIMESTAMP,
+	`updated_at` integer DEFAULT CURRENT_TIMESTAMP
 );
 --> statement-breakpoint
 CREATE TABLE `merge_request_commits` (
 	`id` integer PRIMARY KEY NOT NULL,
 	`merge_request_id` integer NOT NULL,
 	`external_id` text NOT NULL,
-	`created_at` text NOT NULL,
+	`commit_created_at` text NOT NULL,
 	`authored_date` text,
 	`committed_date` text,
 	`title` text NOT NULL,
 	`message` text NOT NULL,
 	`author_name` text NOT NULL,
 	`author_email` text NOT NULL,
 	`committer_name` text,
-	`committer_email` text
+	`committer_email` text,
+	`created_at` integer DEFAULT CURRENT_TIMESTAMP,
+	`updated_at` integer DEFAULT CURRENT_TIMESTAMP
 );
 --> statement-breakpoint
 CREATE TABLE `merge_request_diffs` (
@@ -30,23 +34,47 @@ CREATE TABLE `merge_request_diffs` (
 	`new_file` integer NOT NULL,
 	`renamed_file` integer NOT NULL,
 	`deleted_file` integer NOT NULL,
-	`diff` text NOT NULL
+	`diff` text NOT NULL,
+	`created_at` integer DEFAULT CURRENT_TIMESTAMP,
+	`updated_at` integer DEFAULT CURRENT_TIMESTAMP
 );
 --> statement-breakpoint
 CREATE TABLE `merge_requests` (
 	`id` integer PRIMARY KEY NOT NULL,
 	`external_id` integer NOT NULL,
 	`merge_request_id` integer NOT NULL,
-	`repository_id` integer NOT NULL
+	`repository_id` integer NOT NULL,
+	`created_at` integer DEFAULT CURRENT_TIMESTAMP,
+	`updated_at` integer DEFAULT CURRENT_TIMESTAMP
+);
+--> statement-breakpoint
+CREATE TABLE `namespaces` (
+	`id` integer PRIMARY KEY NOT NULL,
+	`external_id` integer NOT NULL,
+	`name` text NOT NULL,
+	`created_at` integer DEFAULT CURRENT_TIMESTAMP,
+	`updated_at` integer DEFAULT CURRENT_TIMESTAMP
+);
+--> statement-breakpoint
+CREATE TABLE `repositories` (
+	`id` integer PRIMARY KEY NOT NULL,
+	`external_id` integer NOT NULL,
+	`name` text NOT NULL,
+	`created_at` integer DEFAULT CURRENT_TIMESTAMP,
+	`updated_at` integer DEFAULT CURRENT_TIMESTAMP
 );
 --> statement-breakpoint
 CREATE TABLE `repositories_to_members` (
 	`repository_id` integer NOT NULL,
 	`member_id` integer NOT NULL,
+	`created_at` integer DEFAULT CURRENT_TIMESTAMP,
+	`updated_at` integer DEFAULT CURRENT_TIMESTAMP,
 	PRIMARY KEY(`member_id`, `repository_id`)
 );
 --> statement-breakpoint
 CREATE UNIQUE INDEX `members_external_id_idx` ON `members` (`external_id`);--> statement-breakpoint
 CREATE UNIQUE INDEX `merge_request_commits_external_id_idx` ON `merge_request_commits` (`external_id`);--> statement-breakpoint
 CREATE UNIQUE INDEX `diffs_merge_request_id_newPath_idx` ON `merge_request_diffs` (`merge_request_id`,`new_path`);--> statement-breakpoint
-CREATE UNIQUE INDEX `merge_requests_external_id_idx` ON `merge_requests` (`external_id`);
+CREATE UNIQUE INDEX `merge_requests_external_id_idx` ON `merge_requests` (`external_id`);--> statement-breakpoint
+CREATE UNIQUE INDEX `namespaces_external_id_idx` ON `namespaces` (`external_id`);--> statement-breakpoint
+CREATE UNIQUE INDEX `repositories_external_id_idx` ON `repositories` (`external_id`);