ngrx signal store wip

Author: Lukecsharpwalker

src/app/reader/_components/main-page/post/post.component.ts

@@ -4,20 +4,15 @@ import {
   Injector,
   Input,
   OnInit,
-  Signal,
   inject,
-  runInInjectionContext,
   AfterViewInit,
   ViewContainerRef,
   afterNextRender,
 } from '@angular/core';
 import { ReaderApiService } from '../../../_services/reader-api.service';
 import { AsyncPipe, DatePipe } from '@angular/common';
-import { Observable, from, map, of } from 'rxjs';
 import { CommentsComponent } from './comments/comments.component';
 import { AddCommentComponent } from './add-comment/add-comment.component';
-import { toSignal } from '@angular/core/rxjs-interop';
-import { Comment } from '../../../../shared/_models/comment.inteface';
 import { Router } from '@angular/router';
 import { DomSanitizer } from '@angular/platform-browser';
 import { DynamicDialogService } from '../../../../shared/dynamic-dialog/dynamic-dialog.service';
@@ -33,7 +28,6 @@ import { CodeBlockModalComponent } from './code-block-modal-component/code-block
   imports: [AsyncPipe, CommentsComponent, AddCommentComponent, DatePipe],
 })
 export class PostComponent implements OnInit, AfterViewInit {
-  //TODO: add resolver
   @Input() id!: string;
 
   apiService = inject(ReaderApiService);
@@ -45,16 +39,9 @@ export class PostComponent implements OnInit, AfterViewInit {
   private sanitizer = inject(DomSanitizer);
   private viewContainerRef = inject(ViewContainerRef);
 
-  post$!: Observable<any | null>;
-  comments$!: Signal<Comment[] | undefined>;
   date: string = '';
 
-  ngOnInit() {
-    this.post$ = of(null);
-    this.comments$! = runInInjectionContext(this.injector, () =>
-      toSignal(this.apiService.getComments(this.id)),
-    );
-  }
+  ngOnInit() {}
 
   constructor() {
     afterNextRender(() => {

src/app/reader/_services/reader-api.service.ts

@@ -1,24 +1,51 @@
 import { inject, Injectable } from '@angular/core';
 import { Observable } from 'rxjs';
-import { Comment } from '../../shared/_models/comment.inteface';
 import { SupabaseService } from '../../services/supabase.service';
-import { Post } from '../../types/supabase';
+import { Comment, Post } from '../../types/supabase';
 
 @Injectable({ providedIn: 'root' })
 export class ReaderApiService {
   supabaseService = inject(SupabaseService);
 
   async getPost(id: string): Promise<Post | null> {
-    return null;
+    const { data: post, error } = await this.supabaseService.getClient
+      .from('posts')
+      .select(
+        `
+        *,
+        author:profiles ( id, username, avatar_url ),
+        post_tags (
+          tags ( id, name, color, icon )
+        )
+      `,
+      )
+      .eq('id', id)
+      .single();
+    return error ? null : post;
   }
 
-  getComments(postId: string): Observable<Comment[]> {
-    return [] as unknown as Observable<Comment[]>;
+  async getComments(postId: string): Promise<Comment[]> {
+    const { data: comments, error } = await this.supabaseService.getClient
+      .from('comments')
+      .select('*')
+      .eq('post_id', postId)
+      .order('created_at', { ascending: true });
+    return error ? [] : comments;
   }
 
-  addComment(postId: string, comment: Comment): void {}
+  async addComment(postId: string, comment: Comment): Promise<void> {
+    const { error } = await this.supabaseService.getClient
+      .from('comments')
+      .insert({ ...comment, post_id: postId });
+  }
 
-  deleteComment(commentId: string, postId: string): void {}
+  async deleteComment(commentId: string, postId: string): Promise<void> {
+    const { error } = await this.supabaseService.getClient
+      .from('comments')
+      .delete()
+      .eq('id', commentId)
+      .eq('post_id', postId);
+  }
 
   async getPosts(): Promise<Post[] | null> {
     const { data: posts } = await this.supabaseService.getClient