fix: outdated testing (#502)

* fix: outdated testing

* fix: nor running workflow services

* refactor: remove unused imports in object.spec.ts and api.ts

* refactor: remove unused getIntent function from api service

Author: clostao

.github/workflows/services.yml

@@ -5,13 +5,13 @@ on:
     branches:
       - main
     paths:
-      - "backend/**" # Only trigger on changes within auth or backend
-      - "auth/**"
+      - "apps/backend/**" # Only trigger on changes within auth or backend
+      - "apps/auth/**"
       - ".github/**"
   pull_request:
     paths:
-      - "backend/**" # Only trigger on changes within auth or backend
-      - "auth/**"
+      - "apps/backend/**" # Only trigger on changes within auth or backend
+      - "apps/auth/**"
       - ".github/**"
   workflow_dispatch:
 

apps/backend/__tests__/e2e/objects/nodes.spec.ts

@@ -200,14 +200,10 @@ describe('Nodes', () => {
     })
     expect(processArchivalSpy).toHaveBeenCalledTimes(1)
 
-    const populateCachesSpy = jest
-      .spyOn(ObjectUseCases, 'populateCaches')
-      .mockResolvedValue()
     // Mock the callback execution of the event above
     await ObjectUseCases.onObjectArchived(cidToString(cid))
 
     const metadata = await metadataRepository.getMetadata(cidToString(cid))
-    expect(populateCachesSpy).toHaveBeenCalledWith(cidToString(cid))
     expect(metadata).toBeDefined()
     expect(metadata?.is_archived).toBe(true)
   })

apps/backend/__tests__/e2e/objects/object.spec.ts

@@ -10,8 +10,6 @@ import {
 import { uploadFile } from '../../utils/uploads.js'
 import { jest } from '@jest/globals'
 import { v4 } from 'uuid'
-import { downloadService } from '../../../src/infrastructure/services/download/index.js'
-import { Readable } from 'stream'
 import { ForbiddenError } from '../../../src/errors/index.js'
 import { nodesRepository } from '../../../src/infrastructure/repositories/index.js'
 
@@ -72,14 +70,6 @@ describe('Object', () => {
   })
 
   it('isArchived should return true for archived object', async () => {
-    const downloadSpy = jest.spyOn(downloadService, 'download')
-    downloadSpy.mockResolvedValueOnce(
-      new Readable({
-        read: async function () {
-          this.push(null)
-        },
-      }),
-    )
     await nodesRepository.saveNode({
       cid: fileCid,
       root_cid: fileCid,
@@ -94,7 +84,6 @@ describe('Object', () => {
     await ObjectUseCases.onObjectArchived(fileCid)
     const isArchived = await ObjectUseCases.isArchived(fileCid)
     expect(isArchived).toBe(true)
-    expect(downloadSpy).toHaveBeenCalledTimes(1)
   })
 
   it('should get listed in user objects', async () => {

apps/backend/migrations/sqls/20250924123851-update-nodes-constraint-down.sql

@@ -1 +0,0 @@
-ALTER TABLE nodes ADD CONSTRAINT nodes_pkey PRIMARY KEY (cid);

apps/backend/src/infrastructure/repositories/objects/nodes.ts

@@ -42,7 +42,7 @@ const saveNodes = async (nodes: Node[]) => {
 
   return db.query({
     text: pgFormat(
-      'INSERT INTO nodes (cid, root_cid, head_cid, type, encoded_node, piece_index, piece_offset, block_published_on, tx_published_on) VALUES %L ON CONFLICT (cid) DO NOTHING',
+      'INSERT INTO nodes (cid, root_cid, head_cid, type, encoded_node, piece_index, piece_offset, block_published_on, tx_published_on) VALUES %L',
       nodes.map((node) => [
         node.cid,
         node.root_cid,

apps/frontend/src/services/api.ts

@@ -4,7 +4,6 @@ import {
   AccountModel,
   ObjectInformation,
   DownloadStatus,
-  Intent,
 } from '@auto-drive/models';
 import { getAuthSession } from 'utils/auth';
 import { uploadFileContent } from 'utils/file';
@@ -68,25 +67,6 @@ export const createApiService = ({
       throw new Error(`Network response was not ok: ${response.statusText}`);
     }
   },
-  getIntent: async (intentId: string): Promise<Intent> => {
-    const session = await getAuthSession();
-    if (!session?.authProvider || !session.accessToken) {
-      throw new Error('No session');
-    }
-
-    const response = await fetch(`${apiBaseUrl}/intents/${intentId}`, {
-      headers: {
-        Authorization: `Bearer ${session.accessToken}`,
-        'X-Auth-Provider': session.authProvider,
-      },
-    });
-
-    if (!response.ok) {
-      throw new Error(`Network response was not ok: ${response.statusText}`);
-    }
-
-    return response.json() as Promise<Intent>;
-  },
   getAccount: async (): Promise<AccountInfo> => {
     const session = await getAuthSession();
     if (!session?.authProvider || !session.accessToken) {