Rename query events

packages/aegis/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@jujulego/aegis",
-  "version": "1.0.0-rc.2",
+  "version": "1.0.0-rc.3",
   "license": "MIT",
   "author": "Julien Capellari <julien.capellari@google.com>",
   "repository": {
@@ -35,7 +35,7 @@
     "regenerator-runtime": "^0.13.0"
   },
   "dependencies": {
-    "@jujulego/aegis-core": "^1.0.0-rc.1"
+    "@jujulego/aegis-core": "^1.0.0-rc.2"
   },
   "devDependencies": {
     "@jujulego/flow": "1.1.0",

packages/aegis/src/item.ts

@@ -73,11 +73,11 @@ export function $item<D, I extends AegisId>(entity: Entity<D>, arg1: I | Query<D
     };
 
     // Events
-    arg1.subscribe('update.failed', (state, mtd) => {
-      events.emit('query.failed', state, { source: mtd.source });
+    arg1.subscribe('status.failed', (state, mtd) => {
+      events.emit('status.failed', state, { source: mtd.source });
     });
 
-    arg1.subscribe('update.completed', ({ result }, mtd) => {
+    arg1.subscribe('status.completed', ({ result }, mtd) => {
       const id = entity.storeItem(result);
       const $item = entity.item(id);
 
@@ -90,11 +90,11 @@ export function $item<D, I extends AegisId>(entity: Entity<D>, arg1: I | Query<D
         events.emit(mtd.type, data, { source: mtd.source });
       });
 
-      $item.subscribe('query', (data, mtd) => {
+      $item.subscribe('status', (data, mtd) => {
         events.emit(mtd.type, data, { source: mtd.source });
       });
 
-      events.emit('query.completed', { status: 'completed', result: result }, { source: mtd.source });
+      events.emit('status.completed', { status: 'completed', result: result }, { source: mtd.source });
     });
 
     return item;

packages/aegis/src/mutation.ts

@@ -56,7 +56,7 @@ export function $mutation<D, I extends AegisId>(entity: Entity<D>, query: Query<
   };
 
   if (!id) {
-    (query as Query<D>).subscribe('update.completed', (data) => {
+    (query as Query<D>).subscribe('status.completed', (data) => {
       Object.assign(mutation, {
         $id: JSON.parse(entity.storeItem(data.result))
       });

packages/aegis/tests/item.test.ts

@@ -97,14 +97,14 @@ describe('$item', () => {
       expect(item.data).toEqual({ id: 'test', success: false });
     });
 
-    it('should emit query manager events (query.pending)', () => {
+    it('should emit query manager events (status.pending)', () => {
       const item = $item(entity, query);
 
       query.complete({ id: 'test', success: true });
 
       // Register listener
       const spy = jest.fn();
-      item.subscribe('query.pending', spy);
+      item.subscribe('status.pending', spy);
 
       // Emit event
       item.$item?.refresh(() => new Query(), 'replace');
@@ -114,15 +114,15 @@ describe('$item', () => {
           status: 'pending'
         },
         {
-          type: 'query.pending',
+          type: 'status.pending',
           source: item.$item?.manager,
         }
       );
 
       expect(item.isLoading).toBe(true);
     });
 
-    it('should emit query manager events (query.completed)', () => {
+    it('should emit query manager events (status.completed)', () => {
       const item = $item(entity, query);
       query.complete({ id: 'test', success: true });
 
@@ -132,7 +132,7 @@ describe('$item', () => {
 
       // Register listener
       const spy = jest.fn();
-      item.subscribe('query.completed', spy);
+      item.subscribe('status.completed', spy);
 
       // Emit event
       q2.complete({ id: 'test', success: false });
@@ -143,15 +143,15 @@ describe('$item', () => {
           result: { id: 'test', success: false }
         },
         {
-          type: 'query.completed',
+          type: 'status.completed',
           source: q2,
         }
       );
 
       expect(item.isLoading).toBe(false);
     });
 
-    it('should emit query manager events (query.failed)', () => {
+    it('should emit query manager events (status.failed)', () => {
       const item = $item(entity, query);
       query.complete({ id: 'test', success: true });
 
@@ -161,7 +161,7 @@ describe('$item', () => {
 
       // Register listener
       const spy = jest.fn();
-      item.subscribe('query.failed', spy);
+      item.subscribe('status.failed', spy);
 
       // Emit event
       q2.fail(new Error('Failed !'));
@@ -172,23 +172,23 @@ describe('$item', () => {
           error: new Error('Failed !')
         },
         {
-          type: 'query.failed',
+          type: 'status.failed',
           source: q2,
         }
       );
 
       expect(item.isLoading).toBe(false);
     });
 
-    it('should emit query events (query.completed)', () => {
+    it('should emit query events (status.completed)', () => {
       const item = $item(entity, query);
 
       expect(item.$entity).toBe(entity);
       expect(item.isLoading).toBe(true);
 
       // Register listener
       const spy = jest.fn();
-      item.subscribe('query.completed', spy);
+      item.subscribe('status.completed', spy);
 
       // Emit event
       query.complete({ id: 'test', success: true });
@@ -199,23 +199,23 @@ describe('$item', () => {
           result: { id: 'test', success: true }
         },
         {
-          type: 'query.completed',
+          type: 'status.completed',
           source: query,
         }
       );
 
       expect(item.isLoading).toBe(false);
     });
 
-    it('should emit query events (query.failed)', () => {
+    it('should emit query events (status.failed)', () => {
       const item = $item(entity, query);
 
       expect(item.$entity).toBe(entity);
       expect(item.isLoading).toBe(true);
 
       // Register listener
       const spy = jest.fn();
-      item.subscribe('query.failed', spy);
+      item.subscribe('status.failed', spy);
 
       // Emit event
       query.fail(new Error('Failed !'));
@@ -226,7 +226,7 @@ describe('$item', () => {
           error: new Error('Failed !')
         },
         {
-          type: 'query.failed',
+          type: 'status.failed',
           source: query,
         }
       );
@@ -323,12 +323,12 @@ describe('$item', () => {
       expect(item.data).toEqual({ id: 'test', success: false });
     });
 
-    it('should emit query manager events (query.pending)', () => {
+    it('should emit query manager events (status.pending)', () => {
       const item = $item(entity, 'test');
 
       // Register listener
       const spy = jest.fn();
-      item.subscribe('query.pending', spy);
+      item.subscribe('status.pending', spy);
 
       // Emit event
       item.$item.refresh(() => new Query(), 'replace');
@@ -338,15 +338,15 @@ describe('$item', () => {
           status: 'pending'
         },
         {
-          type: 'query.pending',
+          type: 'status.pending',
           source: item.$item.manager,
         }
       );
 
       expect(item.isLoading).toBe(true);
     });
 
-    it('should emit query manager events (query.completed)', () => {
+    it('should emit query manager events (status.completed)', () => {
       const item = $item(entity, 'test');
 
       // Refresh query
@@ -355,7 +355,7 @@ describe('$item', () => {
 
       // Register listener
       const spy = jest.fn();
-      item.subscribe('query.completed', spy);
+      item.subscribe('status.completed', spy);
 
       // Emit event
       query.complete({ id: 'test', success: false });
@@ -366,15 +366,15 @@ describe('$item', () => {
           result: { id: 'test', success: false }
         },
         {
-          type: 'query.completed',
+          type: 'status.completed',
           source: query,
         }
       );
 
       expect(item.isLoading).toBe(false);
     });
 
-    it('should emit query manager events (query.failed)', () => {
+    it('should emit query manager events (status.failed)', () => {
       const item = $item(entity, 'test');
 
       // Refresh query
@@ -383,7 +383,7 @@ describe('$item', () => {
 
       // Register listener
       const spy = jest.fn();
-      item.subscribe('query.failed', spy);
+      item.subscribe('status.failed', spy);
 
       // Emit event
       query.fail(new Error('Failed !'));
@@ -394,7 +394,7 @@ describe('$item', () => {
           error: new Error('Failed !')
         },
         {
-          type: 'query.failed',
+          type: 'status.failed',
           source: query,
         }
       );