Kavita to Obsidian

// Effect Service pattern example
export class KavitaClient extends Effect.Service<KavitaClient>()(
  "KavitaClient",
  {
    effect: Effect.gen(function* () {
      const config = yield* PluginConfig;
      const httpClient = yield* HttpClient.HttpClient;

      return {
        fetchAllAnnotations: () =>
          Effect.gen(function* () {
            const response = yield* httpClient.get("/api/Annotation");
            return yield* HttpClientResponse.schemaBodyJson(
              Schema.Array(AnnotationDto)
            )(response);
          }).pipe(
            Effect.mapError((e) => new KavitaNetworkError({ url: "/api/Annotation", cause: e }))
          ),
      };
    }),
    dependencies: [PluginConfig.Default],
  }
) {}

// Layer composition in plugin entry
const ConfigLayer = PluginConfig.fromSettings(this.settings);
const ObsidianAppLayer = Layer.succeed(ObsidianApp, this.app);

const ObsidianAdapterLayer = ObsidianAdapter.Default.pipe(
  Layer.provide(ObsidianAppLayer),
);

const KavitaClientLayer = KavitaClient.DefaultWithoutDependencies.pipe(
  Layer.provide(ConfigLayer),
  Layer.provide(ObsidianHttpClient),
);

const SyncerLayer = AnnotationSyncer.Default.pipe(
  Layer.provide(KavitaClientLayer),
  Layer.provide(ObsidianAdapterLayer),
  Layer.provide(ConfigLayer),
);

// Tagged errors with structured properties
export class KavitaNetworkError extends Schema.TaggedError<KavitaNetworkError>()(
  "KavitaNetworkError",
  {
    url: Schema.String,
    statusCode: Schema.optionalWith(Schema.Number, { exact: true }),
    cause: Schema.optionalWith(Schema.Defect, { exact: true }),
  }
) {
  override get message(): string {
    return `Network error calling ${this.url}`;
  }
}

export class KavitaAuthError extends Schema.TaggedError<KavitaAuthError>()(
  "KavitaAuthError",
  {
    reason: Schema.String,
  }
) {
  override get message(): string {
    return `Authentication failed: ${this.reason}`;
  }
}

// 25+ DTO schemas for API responses
export class AnnotationDto extends Schema.Class<AnnotationDto>("AnnotationDto")({
  id: Schema.Number,
  content: Schema.String,
  pageNumber: Schema.Number,
  chapterId: Schema.Number,
  seriesId: Schema.Number,
  libraryId: Schema.Number,
  isSpoiler: Schema.Boolean,
  createdUtc: Schema.String,
  lastModifiedUtc: Schema.String,
  // ... 8 more fields
}) {}

export class SeriesMetadataDto extends Schema.Class<SeriesMetadataDto>(
  "SeriesMetadataDto"
)({
  writers: Schema.Array(PersonDto),
  genres: Schema.Array(GenreDto),
  tags: Schema.Array(TagDto),
  // Complex nested structure with full validation
}) {}

---
title: Reading Annotations
synced_at: 2025-12-08T10:30:00.000Z
source: kavita
tags:
  - fiction/sci-fi
  - series/the-expanse
  - book/leviathan-wakes
---

## The Expanse

### Leviathan Wakes

#### Chapter 1: Prologue

> "The stars are better off without us."
>
> — Page 12

*A haunting opening that sets the tone for the entire series.*

> "There was a button. Miller pushed it."
>
> — Page 45

#### Chapter 2: Miller

> "Doors and corners, kid. That's where they get you."
>
> — Page 78

[[James S.A. Corey]] | #fiction #sci-fi #space-opera

// Pure formatting functions
export function formatAnnotation(
  annotation: AnnotationDto,
  config: PluginConfigShape
): Option.Option<string> {
  // Filter spoilers if configured
  if (annotation.isSpoiler && !config.includeSpoilers) {
    return Option.none();
  }

  const lines: string[] = [];

  // Blockquote with proper multi-line handling
  const paragraphs = annotation.content.split("\n\n");
  lines.push("> " + paragraphs.join("\n>\n> "));

  // Page number if available
  if (annotation.pageNumber > 0) {
    lines.push(`>\n> — Page ${annotation.pageNumber}`);
  }

  // User comment if present
  if (annotation.comment) {
    lines.push(`\n*${annotation.comment}*`);
  }

  return Option.some(lines.join("\n"));
}