refactor(StreamIssueRepo):

src/Renderer/Infra/Stream.ts

@@ -140,7 +140,9 @@ export class Stream {
     }
 
     const {updatedIssueIds} = await IssueRepo.import(issues);
-    await StreamsIssuesRepo.import(this.id, issues);
+    const {error: e1} = await StreamsIssuesRepo.createBulk(this.id, issues);
+    if (e1) return {error: e1};
+
     if (updatedIssueIds.length) {
       console.log(`[updated] stream: ${this.id}, name: ${this.name}, page: ${this.page}, totalCount: ${body.total_count}, updatedIssues: ${updatedIssueIds.length}`);
     }

src/Renderer/Repository/IssueRepo.ts

@@ -6,6 +6,7 @@ import moment from 'moment';
 import {IssueEvent} from '../Event/IssueEvent';
 import {IssueFilter} from './Issue/IssueFilter';
 
+// todo: refactor
 class _IssueRepo {
   async getCount(): Promise<{error?: Error; count?: number}>{
     const {error, row} = await DBIPC.selectSingle('select count(1) as count from issues');

src/Renderer/Repository/LibraryStreamRepo.ts

@@ -1,6 +1,7 @@
 import {DBIPC} from '../../IPC/DBIPC';
 import {LibraryStreamEntity} from '../Type/LibraryStreamEntity';
 
+// todo: remove comments
 class _LibraryStreamRepo {
   async getAllLibraryStreams(): Promise<{error?: Error; libraryStreams?: LibraryStreamEntity[]}> {
     const promises = [

src/Renderer/Repository/StreamsIssuesRepo.ts

@@ -1,28 +1,57 @@
 import {DBIPC} from '../../IPC/DBIPC';
 import {StreamRepo} from './StreamRepo';
 import {GitHubQueryParser} from '../Infra/GitHubQueryParser';
+import {IssueEntity} from '../../Type/IssueEntity';
+import {StreamIssueEntity} from '../../Type/StreamIssueEntity';
 
 class _StreamsIssuesRepo {
-  async import(streamId: number, issues: any[]) {
-    for (const issue of issues) {
-      const params = [streamId, issue.id];
-      const res = await DBIPC.selectSingle(`select * from streams_issues where stream_id = ? and issue_id = ?`, params);
-      if (!res.row) {
-        await DBIPC.exec('insert into streams_issues (stream_id, issue_id) values (?, ?)', params);
-      }
-    }
+  async createBulk(streamId: number, issues: IssueEntity[]): Promise<{error?: Error}> {
+    if (!issues.length) return {};
+
+    // get StreamIssue
+    const {error: e1, rows} = await DBIPC.select<StreamIssueEntity>(`select * from streams_issues where stream_id = ?`, [streamId]);
+    if (e1) return {error: e1};
+
+    // filter notExistIssues
+    const existIssueIds = rows.map(row => row.issue_id);
+    const notExistIssues = issues.filter(issue => !existIssueIds.includes(issue.id));
+    if (!notExistIssues.length) return {};
 
+    // insert bulk issues
+    const bulkParams = notExistIssues.map(issue => `(${streamId}, ${issue.id})`);
+    const {error: e2} = await DBIPC.exec(`insert into streams_issues (stream_id, issue_id) values ${bulkParams.join(',')}`);
+    if (e2) return {error: e2};
+
+    // unlink mismatch issues
     await this.unlinkMismatchIssues(issues);
 
-    // see IssuesTable
-    await DBIPC.exec(`
-      delete from
-        streams_issues
-      where
-        issue_id not in (select id from issues)
-    `);
+    // delete unlinked issues
+    const {error: e3} = await DBIPC.exec(`delete from streams_issues where issue_id not in (select id from issues)`);
+    if (e3) return {error: e3};
+
+    return {};
   }
 
+  // async import(streamId: number, issues: any[]) {
+  //   for (const issue of issues) {
+  //     const params = [streamId, issue.id];
+  //     const res = await DBIPC.selectSingle(`select * from streams_issues where stream_id = ? and issue_id = ?`, params);
+  //     if (!res.row) {
+  //       await DBIPC.exec('insert into streams_issues (stream_id, issue_id) values (?, ?)', params);
+  //     }
+  //   }
+  //
+  //   await this.unlinkMismatchIssues(issues);
+  //
+  //   // see IssuesTable
+  //   await DBIPC.exec(`
+  //     delete from
+  //       streams_issues
+  //     where
+  //       issue_id not in (select id from issues)
+  //   `);
+  // }
+
   private async unlinkMismatchIssues(issues: any[]) {
     if (!issues.length) return;
 

src/Renderer/Repository/SystemStreamRepo.ts

@@ -115,7 +115,8 @@ class _SystemStreamRepo {
     const issue = res.body;
 
     await IssueRepo.import([issue]);
-    await StreamsIssuesRepo.import(this.STREAM_ID_SUBSCRIPTION, [issue]);
+    const {error} = await StreamsIssuesRepo.createBulk(this.STREAM_ID_SUBSCRIPTION, [issue]);
+    if (error) return console.error(error);
 
     const createdAt = moment(new Date()).utc().format('YYYY-MM-DDTHH:mm:ss[Z]');
     await DBIPC.exec(`

src/Type/IssueEntity.ts

@@ -0,0 +1,25 @@
+export type IssueEntity = {
+  id: number;
+  type: string;
+  title: string;
+  created_at: string;
+  updated_at: string;
+  closed_at: string;
+  read_at: string;
+  prev_read_at: string;
+  archived_at: string;
+  marked_at: string;
+  number: number;
+  user: string;
+  repo: string;
+  author: string;
+  assignees: string;
+  labels: string;
+  milestone: string;
+  due_on: string;
+  html_url: string;
+  body: string;
+  read_body: string;
+  prev_read_body: string;
+  value: string;
+}

src/Type/StreamIssueEntity.ts

@@ -0,0 +1,4 @@
+export type StreamIssueEntity = {
+  stream_id: number;
+  issue_id: number;
+}