add allshows

src/mappings.ts

@@ -66,4 +66,21 @@ export function transformEpisodeList(input: any): ActivityPubOutbox {
       type: "OrderedCollection",
       orderedItems,
     };
+  }
+
+  export function transformShows(nodes: any) {
+    const items: ActivityPubNote[] = nodes.map((show: any) => ({
+      id: show.coreId,
+      type: "Service",
+      actor: 'TODO',
+      to: ["https://www.w3.org/ns/activitystreams#Public"],
+      name: show.title,
+      url: show.url,
+    }));
+    
+    return {
+      type: "Collection",
+      items,
+      "@context": "https://www.w3.org/ns/activitystreams",
+    };
   }
\ No newline at end of file

src/server.ts

@@ -2,7 +2,7 @@ import express from 'express';
 
 import { Client, cacheExchange, fetchExchange, gql } from '@urql/core';
 import { EpisodeResponse } from './types';
-import { transformEpisode, transformEpisodeList } from './mappings';
+import { transformEpisode, transformEpisodeList, transformShows } from './mappings';
 
 const app = express();
 const PORT = 3000;
@@ -161,6 +161,48 @@ app.get('/:actor/outbox', async (req, res) => {
 	});
 });
 
+app.get('/shows', async (req, res) => {
+	const query = gql`
+		query AllShows {
+  shows: programSets(orderBy: LAST_ITEM_MODIFIED_DESC, filter: {numberOfElements: {notEqualTo: 0}}) {
+    totalCount
+    nodes {
+      coreId
+      title
+      lastItemAdded
+      lastItemModified
+      url: sharingUrl
+      publicationService {
+        title
+        dvbServiceId
+        organization {
+          name
+        }
+      }
+    }
+  }
+}
+	`;
+
+	const data = await fetchData<any>(query, {  });
+	if (!data) {
+		res.status(404).json({ error: 'Shows not found' });
+		return;
+	}
+
+	const { nodes, totalCount } = data.shows;
+
+	res.json({
+		id: `${root}/TODO`,
+		to: ['https://www.w3.org/ns/activitystreams#Public'],
+		totalItems: totalCount,
+		first: `${root}/shows?page=1`,
+		current: `${root}/outbox`,
+		last: `${root}/shows?page=${Math.floor(totalCount / 10)}`,
+    ...transformShows(nodes)
+	});
+});
+
 app.get('/:actor', async (req, res) => {
 	res.json({
 		'@context': 'https://www.w3.org/ns/activitystreams',
@@ -184,6 +226,9 @@ app.get('/:actor', async (req, res) => {
 
 app.get('/', (req, res) => res.redirect('/@blaue-couch'));
 
+
 app.listen(PORT, () => {
 	console.log(`Server running at http://localhost:${PORT}`);
 });
+
+