feat: add personalized following k3l algo

packages/data/vitest.config.ts

@@ -1,5 +1,5 @@
 import { defineConfig } from 'vitest/config';
 
 export default defineConfig({
-  test: { globals: true }
+  test: { globals: true, testTimeout: 30000 }
 });

packages/lens/vitest.config.ts

@@ -1,5 +1,5 @@
 import { defineConfig } from 'vitest/config';
 
 export default defineConfig({
-  test: { globals: true }
+  test: { globals: true, testTimeout: 30000 }
 });

packages/lib/vitest.config.ts

@@ -1,5 +1,5 @@
 import { defineConfig } from 'vitest/config';
 
 export default defineConfig({
-  test: { globals: true }
+  test: { globals: true, testTimeout: 30000 }
 });

packages/workers/ens/vitest.config.ts

@@ -1,5 +1,5 @@
 import { defineConfig } from 'vitest/config';
 
 export default defineConfig({
-  test: { globals: true }
+  test: { globals: true, testTimeout: 30000 }
 });

packages/workers/feeds/src/handlers/getPublicationIds.spec.ts

@@ -39,5 +39,13 @@ describe('getPublicationIds', () => {
       const response: Response = await getRequest.json();
       expect(response.ids.length).toBe(50);
     });
+
+    test('should return ids for k3l provider, following strategy and profile', async () => {
+      const getRequest = await fetch(
+        `${TEST_URL}/ids?provider=k3l&strategy=following&profile=yoginth.lens`
+      );
+      const response: Response = await getRequest.json();
+      expect(response.ids.length).toBe(50);
+    });
   });
 });

packages/workers/feeds/src/handlers/getPublicationIds.ts

@@ -8,6 +8,7 @@ import type { Env } from '../types';
 export default async (request: IRequest, env: Env) => {
   const provider = request.query.provider as string;
   const strategy = request.query.strategy as string;
+  const profile = request.query.profile as string;
   const limit = (parseInt(request.query?.limit as string) || 50) as number;
   const offset = (parseInt(request.query?.offset as string) || 0) as number;
 
@@ -24,7 +25,7 @@ export default async (request: IRequest, env: Env) => {
     let ids: string[] = [];
     switch (provider) {
       case AlgorithmProvider.K3L:
-        ids = await k3lFeed(strategy, limit, offset);
+        ids = await k3lFeed(strategy, profile, limit, offset);
         break;
       case AlgorithmProvider.LENSTER:
         ids = await lensterFeed(strategy, limit, offset, env);

packages/workers/feeds/src/providers/k3l/algorithms/k3lGlobalFeed.ts

@@ -0,0 +1,25 @@
+import randomizeIds from '../../../helpers/randomizeIds';
+
+const k3lGlobalFeed = async (
+  strategy: string,
+  limit: number,
+  offset: number
+) => {
+  try {
+    const response = await fetch(
+      `https://lens-api.k3l.io/feed/${strategy}?limit=${limit}&offset=${offset}`,
+      { headers: { 'User-Agent': 'Lenster' } }
+    );
+    const json: {
+      postId: string;
+    }[] = await response.json();
+    const ids = json.map((item: any) => item.postId);
+
+    return randomizeIds(ids);
+  } catch (error) {
+    console.log(error);
+    return [];
+  }
+};
+
+export default k3lGlobalFeed;

packages/workers/feeds/src/providers/k3l/algorithms/k3lPersonalFeed.ts

@@ -0,0 +1,26 @@
+import randomizeIds from '../../../helpers/randomizeIds';
+
+const k3lPersonalFeed = async (
+  strategy: string,
+  profile: string,
+  limit: number,
+  offset: number
+) => {
+  try {
+    const response = await fetch(
+      `https://lens-api.k3l.io/feed/personal/${profile}/${strategy}?limit=${limit}&offset=${offset}`,
+      { headers: { 'User-Agent': 'Lenster' } }
+    );
+    const json: {
+      postId: string;
+    }[] = await response.json();
+    const ids = json.map((item: any) => item.postId);
+
+    return randomizeIds(ids);
+  } catch (error) {
+    console.log(error);
+    return [];
+  }
+};
+
+export default k3lPersonalFeed;

packages/workers/feeds/src/providers/k3l/k3lFeed.ts

@@ -1,21 +1,17 @@
-import randomizeIds from '../../helpers/randomizeIds';
+import k3lGlobalFeed from './algorithms/k3lGlobalFeed';
+import k3lPersonalFeed from './algorithms/k3lPersonalFeed';
 
-const k3lFeed = async (strategy: string, limit: number, offset: number) => {
-  try {
-    const response = await fetch(
-      `https://lens-api.k3l.io/feed/${strategy}?limit=${limit}&offset=${offset}`,
-      { headers: { 'User-Agent': 'Lenster' } }
-    );
-    const json: {
-      postId: string;
-    }[] = await response.json();
-    const ids = json.map((item: any) => item.postId);
-
-    return randomizeIds(ids);
-  } catch (error) {
-    console.log(error);
-    return [];
+const k3lFeed = async (
+  strategy: string,
+  profile: string,
+  limit: number,
+  offset: number
+) => {
+  if (profile) {
+    return await k3lPersonalFeed(strategy, profile, limit, offset);
   }
+
+  return await k3lGlobalFeed(strategy, limit, offset);
 };
 
 export default k3lFeed;

packages/workers/feeds/vitest.config.ts

@@ -1,5 +1,5 @@
 import { defineConfig } from 'vitest/config';
 
 export default defineConfig({
-  test: { globals: true }
+  test: { globals: true, testTimeout: 30000 }
 });

packages/workers/ipfs/vitest.config.ts

@@ -1,5 +1,5 @@
 import { defineConfig } from 'vitest/config';
 
 export default defineConfig({
-  test: { globals: true }
+  test: { globals: true, testTimeout: 30000 }
 });

packages/workers/metadata/vitest.config.ts

@@ -1,5 +1,5 @@
 import { defineConfig } from 'vitest/config';
 
 export default defineConfig({
-  test: { globals: true }
+  test: { globals: true, testTimeout: 30000 }
 });

packages/workers/oembed/vitest.config.ts

@@ -1,5 +1,5 @@
 import { defineConfig } from 'vitest/config';
 
 export default defineConfig({
-  test: { globals: true }
+  test: { globals: true, testTimeout: 30000 }
 });