Fix: linting

packages/repco-cli/src/commands/ds.ts

@@ -71,7 +71,7 @@ export const add = createCommand({
   },
   async run(opts, args) {
     const repo = await Repo.openWithDefaults(opts.repo)
-    const prisma = repo.prisma
+    // const prisma = repo.prisma
     const config = JSON.parse(args.config)
     const instance = await repo.dsr.create(
       repo.prisma,

packages/repco-core/src/datasource.ts

@@ -124,9 +124,9 @@ export abstract class BaseDataSource implements DataSource {
 
 type FailedHydrates = { err: Error; row: any }
 
-function errToSerializable(err: Error): Prisma.InputJsonValue {
-  return Object.fromEntries(Object.entries(err))
-}
+// function errToSerializable(err: Error): Prisma.InputJsonValue {
+//   return Object.fromEntries(Object.entries(err))
+// }
 
 export class DataSourceRegistry extends Registry<DataSource> {
   _hydrating?: Promise<{ failed: FailedHydrates[] }>
@@ -151,6 +151,8 @@ export class DataSourceRegistry extends Registry<DataSource> {
 
     for (const [uid, uris] of Object.entries(buckets)) {
       const filteredUris = uris.filter((uri) => !found.has(uri))
+      // checked above
+      // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
       const ds = this.get(uid)!
       const sourceRecords = await ds.fetchByUriBatch(filteredUris)
       const entities = await mapAndPersistSourceRecord(repo, ds, sourceRecords)

packages/repco-core/src/datasources/activitypub.ts

@@ -242,14 +242,15 @@ export class ActivityPubDataSource
         }
         // iterate over items on page backwards to find items that are newer than the cursor
         for (let i = items.length - 1; i >= 0; i--) {
-          if (items[i] === undefined) {
+          const item = items[i]
+          if (item === undefined) {
             continue
           }
-          if (new Date(items[i]!.published) <= cursor.lastPublishedDate) {
+          if (new Date(item.published) <= cursor.lastPublishedDate) {
             continue
           }
-          newVideoObjects.push(items[i]!)
-          cursor.lastPublishedDate = new Date(items[i]!.published)
+          newVideoObjects.push(item)
+          cursor.lastPublishedDate = new Date(item.published)
         }
       }
       const records = [

packages/repco-core/src/datasources/cba.ts

@@ -739,9 +739,9 @@ export class CbaDataSource implements DataSource {
 
 /**
  * Parse a datetime string without timezone information as a UTC date
- * 
+ *
  * @param dateString Datetime string in format 1998-10-17T00:00:00
  */
-function parseAsUTC(dateString: string): Date  {
+function parseAsUTC(dateString: string): Date {
   return new Date(dateString + '.000Z')
-}
+}

packages/repco-core/src/datasources/defaults.ts

@@ -1,8 +1,8 @@
+import { ActivityPubDataSourcePlugin } from './activitypub.js'
 import { CbaDataSourcePlugin } from './cba.js'
 import { RssDataSourcePlugin } from './rss.js'
 import { XrcbDataSourcePlugin } from './xrcb.js'
 import { DataSourcePluginRegistry } from '../plugins.js'
-import { ActivityPubDataSourcePlugin } from './activitypub.js'
 
 export const plugins = new DataSourcePluginRegistry()
 

packages/repco-core/src/datasources/rss.ts

@@ -214,26 +214,26 @@ export class RssDataSource extends BaseDataSource implements DataSource {
   }
 
   // TODO: Implement
-  async _crawlBackwardsFrom(cursor: Cursor) {
-    // const lastLeastRecentPubDate = cursor.newest.leastRecentPubDate || new Date()
-    // const maxPageNumber = cursor.newest.maxPageNumber || 0
-    // // TODO: Make configurable
-    // const pagination = {
-    //   offsetParam: 'start',
-    //   limitParam: 'anzahl',
-    //   limit: 5,
-    // }
-    // const url = new URL(this.endpoint)
-    // const page = maxPageNumber + 1
-    // url.searchParams.set(pagination.limitParam, pagination.limit.toString())
-    // url.searchParams.set(
-    //   pagination.offsetParam,
-    //   (page * pagination.limit).toString(),
-    // )
-    // const { feed, entities } = await this.fetchPage(url)
-    // const [newestPubDate, oldestPubDate] = getDateRangeFromFeed(feed)
-    // const nextCursor = { ...cursor }
-  }
+  // async _crawlBackwardsFrom(cursor: Cursor) {
+  // const lastLeastRecentPubDate = cursor.newest.leastRecentPubDate || new Date()
+  // const maxPageNumber = cursor.newest.maxPageNumber || 0
+  // // TODO: Make configurable
+  // const pagination = {
+  //   offsetParam: 'start',
+  //   limitParam: 'anzahl',
+  //   limit: 5,
+  // }
+  // const url = new URL(this.endpoint)
+  // const page = maxPageNumber + 1
+  // url.searchParams.set(pagination.limitParam, pagination.limit.toString())
+  // url.searchParams.set(
+  //   pagination.offsetParam,
+  //   (page * pagination.limit).toString(),
+  // )
+  // const { feed, entities } = await this.fetchPage(url)
+  // const [newestPubDate, oldestPubDate] = getDateRangeFromFeed(feed)
+  // const nextCursor = { ...cursor }
+  // }
 
   async fetchPage(url: URL): Promise<string> {
     // console.log('FETCH', url.toString())

packages/repco-core/src/entity.ts

@@ -6,7 +6,7 @@
  */
 
 import z from 'zod'
-import { RevisionHeaders, revisionHeaders } from 'repco-common/schema'
+import { revisionHeaders } from 'repco-common/schema'
 import { repco } from 'repco-prisma'
 import {
   ConceptKind,

packages/repco-core/src/repo.ts

@@ -1,6 +1,7 @@
 import * as ucans from '@ucans/ucans'
 import * as common from 'repco-common/zod'
 import { CID } from 'multiformats/cid.js'
+import { EventEmitter } from 'node:events'
 import { createLogger, Logger } from 'repco-common'
 import {
   CommitBundle,
@@ -53,7 +54,6 @@ import { ParseError } from './util/error.js'
 import { createEntityId } from './util/id.js'
 import { notEmpty } from './util/misc.js'
 import { Mutex } from './util/mutex.js'
-import { EventEmitter } from 'node:events'
 
 // export * from './repo/types.js'
 
@@ -445,7 +445,10 @@ export class Repo extends EventEmitter {
     return importRepoFromCar(this, stream, onProgress)
   }
 
-  async saveBatch(inputs: UnknownEntityInput[], opts: Partial<SaveBatchOpts> = {}) {
+  async saveBatch(
+    inputs: UnknownEntityInput[],
+    opts: Partial<SaveBatchOpts> = {},
+  ) {
     if (!this.writeable) throw new Error('Repo is not writeable')
     const fullOpts: SaveBatchOpts = { ...SAVE_BATCH_DEFAULTS, ...opts }
 
@@ -779,7 +782,9 @@ function parseEntity(input: UnknownEntityInput): EntityFormWithHeaders {
   }
 }
 
-export function parseEntities(inputs: UnknownEntityInput[]): EntityFormWithHeaders[] {
+export function parseEntities(
+  inputs: UnknownEntityInput[],
+): EntityFormWithHeaders[] {
   return inputs.map(parseEntity)
 }
 

packages/repco-core/src/repo/blockstore.ts

@@ -1,10 +1,10 @@
 import * as Block from 'multiformats/block'
 import * as uint8arrays from 'uint8arrays'
 import * as codec from './codec.js'
-import { blake3 as hasher } from './hash.js'
 import { Level } from 'level'
 import { CID } from 'multiformats/cid'
 import { Prisma } from 'repco-prisma'
+import { blake3 as hasher } from './hash.js'
 
 export async function createCID(value: Uint8Array): Promise<CID> {
   const block = await Block.encode({ value, hasher, codec })

packages/repco-core/src/repo/codec-json.ts

@@ -61,7 +61,8 @@ function preEncode(value: any): Ipld {
 
     if (value instanceof Date) return value.toISOString()
     if (value instanceof CID) return { '/': value.toString() }
-    if (value instanceof Uint8Array || value instanceof Buffer) return { '/': { bytes: uint8arrays.toString(value, 'base64') }}
+    if (value instanceof Uint8Array || value instanceof Buffer)
+      return { '/': { bytes: uint8arrays.toString(value, 'base64') } }
     if (value === undefined || value === null) return null
 
     if (value instanceof Set) value = Array.from(value).sort()
@@ -90,10 +91,20 @@ function postDecode(value: any): any {
       }
       return value
     }
-    if (typeof value === 'object' && Object.keys(value).length === 1 && typeof value['/'] === 'string') {
+    if (
+      typeof value === 'object' &&
+      Object.keys(value).length === 1 &&
+      typeof value['/'] === 'string'
+    ) {
       return CID.parse(value['/'])
     }
-    if (typeof value === 'object' && Object.keys(value).length === 1 && typeof value['/'] === 'object' && Object.keys(value['/']).length === 1 && typeof value['/']['bytes'] === 'string') {
+    if (
+      typeof value === 'object' &&
+      Object.keys(value).length === 1 &&
+      typeof value['/'] === 'object' &&
+      Object.keys(value['/']).length === 1 &&
+      typeof value['/']['bytes'] === 'string'
+    ) {
       return uint8arrays.fromString(value['/']['bytes'], 'base64')
     }
     if (value instanceof CID) return value

packages/repco-core/src/repo/export.ts

@@ -1,9 +1,9 @@
 import { CarWriter } from '@ipld/car'
 import { Block, BlockWriter } from '@ipld/car/api.js'
 import { CID } from 'multiformats/cid'
+import { CommitIpld, RootIpld } from 'repco-common/schema'
 import { Prisma } from 'repco-prisma'
 import { IpldBlockStore } from './blockstore.js'
-import { CommitIpld, RootIpld } from 'repco-common/schema'
 import { Repo } from '../repo.js'
 
 export async function exportRepoToCar(

packages/repco-core/src/repo/graph.ts

@@ -1,7 +1,12 @@
 import { DequeSet } from '../util/collections.js'
 
 export class GGraphError extends Error {
-  constructor(public id: string, public edge: string, public path: string[] | undefined, msg: string) {
+  constructor(
+    public id: string,
+    public edge: string,
+    public path: string[] | undefined,
+    msg: string,
+  ) {
     super(msg)
   }
 }
@@ -26,7 +31,9 @@ export class GGraph {
               id,
               edge,
               path,
-              `Recursion: ${id}->${edge} is invalid because of ${path?.join('->')}`,
+              `Recursion: ${id}->${edge} is invalid because of ${path?.join(
+                '->',
+              )}`,
             )
             throw error
           }

packages/repco-core/src/repo/import.ts

@@ -1,13 +1,6 @@
 import { CarBlockIterator } from '@ipld/car'
 import { Block } from '@ipld/car/api.js'
 import { CID } from 'multiformats/cid.js'
-import { verifyRoot } from './auth.js'
-import {
-  BlockT,
-  parseBytesWith,
-  parseToIpld,
-  validateCID,
-} from './blockstore.js'
 import {
   CommitBundle,
   CommitIpld,
@@ -17,6 +10,13 @@ import {
   RootIpld,
   rootIpld,
 } from 'repco-common/schema'
+import { verifyRoot } from './auth.js'
+import {
+  BlockT,
+  parseBytesWith,
+  parseToIpld,
+  validateCID,
+} from './blockstore.js'
 import { Repo } from '../repo.js'
 
 export type OnProgressCallback = (progress: ImportProgress) => void

packages/repco-core/src/repo/ipld-repo.ts

@@ -1,7 +1,6 @@
 import * as ucans from '@ucans/ucans'
 import * as common from 'repco-common/zod'
 import { CID } from 'multiformats/cid'
-import { IpldBlockStore } from './blockstore.js'
 import {
   CommitBundle,
   CommitForm,
@@ -11,6 +10,7 @@ import {
   revisionIpld,
   rootIpld,
 } from 'repco-common/schema'
+import { IpldBlockStore } from './blockstore.js'
 import { EntityInputWithHeaders } from '../entity.js'
 import { SaveBatchOpts } from '../repo'
 import { createEntityId, createRevisionId } from '../util/id.js'

packages/repco-core/test/activitypub.ts

@@ -1,6 +1,4 @@
 import test from 'brittle'
-import fs from 'fs/promises'
-import p from 'path'
 import { fileURLToPath } from 'node:url'
 import { assertFixture, mockFetch } from './util/fetch.js'
 import { setup } from './util/setup.js'
@@ -9,11 +7,13 @@ import { ingestUpdatesFromDataSources } from '../src/datasource.js'
 import { ActivityPubDataSourcePlugin } from '../src/datasources/activitypub.js'
 import { DataSourcePluginRegistry } from '../src/plugins.js'
 
-
 // Path to fixtures. Resolves to repco-core/test/fixtures/datasource-activitypub/$name
 const fixturePath = (name: string) =>
   fileURLToPath(
-    new URL(`../../test/fixtures/datasource-activitypub/${name}`, import.meta.url),
+    new URL(
+      `../../test/fixtures/datasource-activitypub/${name}`,
+      import.meta.url,
+    ),
   )
 
 test('peertube datasource - basic1', async (assert) => {
@@ -23,13 +23,18 @@ test('peertube datasource - basic1', async (assert) => {
   const plugins = new DataSourcePluginRegistry()
   const activityPubPlugin = new ActivityPubDataSourcePlugin()
   plugins.register(activityPubPlugin)
-  await repo.dsr.create(repo.prisma, plugins, activityPubPlugin.definition.uid, {
-    // user: 'blender_channel',
-    // domain: 'video.blender.org'
-    user: 'cryptix_channel',
-    // user: 'mirsal',
-    domain: 'peertube.1312.media'
-  })
+  await repo.dsr.create(
+    repo.prisma,
+    plugins,
+    activityPubPlugin.definition.uid,
+    {
+      // user: 'blender_channel',
+      // domain: 'video.blender.org'
+      user: 'cryptix_channel',
+      // user: 'mirsal',
+      domain: 'peertube.1312.media',
+    },
+  )
   await ingestUpdatesFromDataSources(repo)
   // TODO: Provide mocking capability to uids
   const entities = await prisma.contentItem.findMany({

packages/repco-core/test/cba.ts

@@ -1,6 +1,4 @@
 import test from 'brittle'
-import fs from 'fs/promises'
-import p from 'path'
 import { fileURLToPath } from 'node:url'
 import { assertFixture, mockFetch } from './util/fetch.js'
 import { setup } from './util/setup.js'
@@ -24,7 +22,7 @@ test('cba datasource - basic1', async (assert) => {
   plugins.register(cbaPlugin)
   await repo.dsr.create(repo.prisma, plugins, cbaPlugin.definition.uid, {
     pageLimit: 2,
-    apiKey: null
+    apiKey: null,
   })
   await ingestUpdatesFromDataSources(repo)
   // TODO: Provide mocking capability to uids

packages/repco-core/test/datasource.ts

@@ -24,8 +24,8 @@ const intoSourceRecord = (body: EntityForm): SourceRecordForm => ({
 
 const DS_UID = 'urn:repco:datasource:test'
 
-const fromSourceRecord = (record: SourceRecordForm) =>
-  JSON.parse(record.body) as EntityForm
+// const fromSourceRecord = (record: SourceRecordForm) =>
+//   JSON.parse(record.body) as EntityForm
 
 class TestDataSourcePlugin implements DataSourcePlugin {
   createInstance(_config: any) {

packages/repco-core/test/util/fetch.ts

@@ -1,6 +1,6 @@
 import fs from 'fs/promises'
-import { Test } from 'brittle'
 import p from 'path'
+import { Test } from 'brittle'
 import { readdirSync, unlinkSync } from 'fs'
 import { getGlobalDispatcher, setGlobalDispatcher } from 'undici'
 import { CachingDispatcher, FsCacheStorage } from '../../src/util/fetch.js'
@@ -17,7 +17,7 @@ export function mockFetch(test: Test, path: string) {
   if (CREATE_FIXTURES) {
     try {
       for (const file of readdirSync(path)) {
-          unlinkSync(p.join(path, file))
+        unlinkSync(p.join(path, file))
       }
     } catch (err) {}
   }

packages/repco-frontend/app/components/player/player.tsx

@@ -380,7 +380,7 @@ function Timeslider({
         max={100}
         type="range"
         aria-label="progress"
-        value={pos * 100}
+        value={value}
         onDragStart={onChangeStart}
         onDragEnd={(e) => onChangeEnd(Number(e.currentTarget.value))}
         onChange={(e) => {