diff --git a/appview/db/artifact.go b/appview/db/artifact.go
index df77a55d..8e938449 100644
--- a/appview/db/artifact.go
+++ b/appview/db/artifact.go
@@ -23,7 +23,7 @@ type Artifact struct {
 	BlobCid  cid.Cid
 	Name     string
 	Size     uint64
-	Mimetype string
+	MimeType string
 }
 
 func (a *Artifact) ArtifactAt() syntax.ATURI {
@@ -52,28 +52,28 @@ func AddArtifact(e Execer, artifact Artifact) error {
 		artifact.BlobCid.String(),
 		artifact.Name,
 		artifact.Size,
-		artifact.Mimetype,
+		artifact.MimeType,
 	)
 	return err
 }
 
-type Filter struct {
+type filter struct {
 	key string
 	arg any
 }
 
-func NewFilter(key string, arg any) Filter {
-	return Filter{
+func Filter(key string, arg any) filter {
+	return filter{
 		key: key,
 		arg: arg,
 	}
 }
 
-func (f Filter) Condition() string {
+func (f filter) Condition() string {
 	return fmt.Sprintf("%s = ?", f.key)
 }
 
-func GetArtifact(e Execer, filters ...Filter) ([]Artifact, error) {
+func GetArtifact(e Execer, filters ...filter) ([]Artifact, error) {
 	var artifacts []Artifact
 
 	var conditions []string
@@ -124,7 +124,7 @@ func GetArtifact(e Execer, filters ...Filter) ([]Artifact, error) {
 			&blobCid,
 			&artifact.Name,
 			&artifact.Size,
-			&artifact.Mimetype,
+			&artifact.MimeType,
 		); err != nil {
 			return nil, err
 		}
@@ -146,7 +146,7 @@ func GetArtifact(e Execer, filters ...Filter) ([]Artifact, error) {
 	return artifacts, nil
 }
 
-func RemoveArtifact(e Execer, filters ...Filter) error {
+func DeleteArtifact(e Execer, filters ...filter) error {
 	var conditions []string
 	var args []any
 	for _, filter := range filters {
diff --git a/appview/ingester.go b/appview/ingester.go
index 75b71214..8079eb3c 100644
--- a/appview/ingester.go
+++ b/appview/ingester.go
@@ -5,10 +5,13 @@ import (
 	"encoding/json"
 	"fmt"
 	"log"
+	"time"
 
 	"github.com/bluesky-social/indigo/atproto/syntax"
 	"github.com/bluesky-social/jetstream/pkg/models"
-	tangled "tangled.sh/tangled.sh/core/api/tangled"
+	"github.com/go-git/go-git/v5/plumbing"
+	"github.com/ipfs/go-cid"
+	"tangled.sh/tangled.sh/core/api/tangled"
 	"tangled.sh/tangled.sh/core/appview/db"
 )
 
@@ -36,6 +39,8 @@ func Ingest(d db.DbWrapper) Ingester {
 			ingestStar(&d, e)
 		case tangled.PublicKeyNSID:
 			ingestPublicKey(&d, e)
+		case tangled.RepoArtifactNSID:
+			ingestArtifact(&d, e)
 		}
 
 		return err
@@ -131,3 +136,53 @@ func ingestPublicKey(d *db.DbWrapper, e *models.Event) error {
 
 	return nil
 }
+
+func ingestArtifact(d *db.DbWrapper, e *models.Event) error {
+	did := e.Did
+	var err error
+
+	switch e.Commit.Operation {
+	case models.CommitOperationCreate, models.CommitOperationUpdate:
+		log.Println("processing add of artifact")
+		raw := json.RawMessage(e.Commit.Record)
+		record := tangled.RepoArtifact{}
+		err = json.Unmarshal(raw, &record)
+		if err != nil {
+			log.Printf("invalid record: %s", err)
+			return err
+		}
+
+		repoAt, err := syntax.ParseATURI(record.Repo)
+		if err != nil {
+			return err
+		}
+
+		createdAt, err := time.Parse(time.RFC3339, record.CreatedAt)
+		if err != nil {
+			createdAt = time.Now()
+		}
+
+		artifact := db.Artifact{
+			Did:       did,
+			Rkey:      e.Commit.RKey,
+			RepoAt:    repoAt,
+			Tag:       plumbing.Hash(record.Tag),
+			CreatedAt: createdAt,
+			BlobCid:   cid.Cid(record.Artifact.Ref),
+			Name:      record.Name,
+			Size:      uint64(record.Artifact.Size),
+			MimeType:  record.Artifact.MimeType,
+		}
+
+		err = db.AddArtifact(d, artifact)
+	case models.CommitOperationDelete:
+		log.Println("processing delete of artifact")
+		err = db.DeleteArtifact(d, db.Filter("did", did), db.Filter("rkey", e.Commit.RKey))
+	}
+
+	if err != nil {
+		return fmt.Errorf("failed to %s artifact record: %w", e.Commit.Operation, err)
+	}
+
+	return nil
+}
diff --git a/appview/pages/pages.go b/appview/pages/pages.go
index 40a39a4e..38a7128a 100644
--- a/appview/pages/pages.go
+++ b/appview/pages/pages.go
@@ -496,7 +496,7 @@ func (p *Pages) RepoTags(w io.Writer, params RepoTagsParams) error {
 
 type RepoArtifactParams struct {
 	LoggedInUser *auth.User
-	RepoInfo     RepoInfo
+	RepoInfo     repoinfo.RepoInfo
 	Artifact     db.Artifact
 }
 
diff --git a/appview/pages/templates/repo/fragments/artifact.html b/appview/pages/templates/repo/fragments/artifact.html
index 3e0a4ba5..bf8849dc 100644
--- a/appview/pages/templates/repo/fragments/artifact.html
+++ b/appview/pages/templates/repo/fragments/artifact.html
@@ -6,17 +6,17 @@
         <a href="/{{ .RepoInfo.FullName }}/tags/{{ .Artifact.Tag.String }}/download/{{ .Artifact.Name | urlquery }}" class="no-underline hover:no-underline">
           {{ .Artifact.Name }}
         </a>
-        <span class="text-gray-500 dark:text-gray-400 pl-2">{{ byteFmt .Artifact.Size }}</span>
+        <span class="text-gray-500 dark:text-gray-400 pl-2 text-sm">{{ byteFmt .Artifact.Size }}</span>
       </div>
 
-    <div id="right-side" class="text-gray-500 dark:text-gray-400 flex items-center flex-shrink-0 gap-2">
+    <div id="right-side" class="text-gray-500 dark:text-gray-400 flex items-center flex-shrink-0 gap-2 text-sm">
       <span title="{{ longTimeFmt .Artifact.CreatedAt }}" class="hidden md:inline">{{ timeFmt .Artifact.CreatedAt }}</span>
       <span title="{{ longTimeFmt .Artifact.CreatedAt }}" class="       md:hidden">{{ shortTimeFmt .Artifact.CreatedAt }}</span>
 
       <span class="select-none after:content-['·'] hidden md:inline"></span>
-      <span class="truncate max-w-[100px] hidden md:inline">{{ .Artifact.Mimetype }}</span>
+      <span class="truncate max-w-[100px] hidden md:inline">{{ .Artifact.MimeType }}</span>
 
-      {{ if and (.LoggedInUser) (eq .LoggedInUser.Did .Artifact.Did) }}
+      {{ if and .LoggedInUser (eq .LoggedInUser.Did .Artifact.Did) }}
         <button
           id="delete-{{ $unique }}"
           class="btn text-red-500 hover:text-red-700 dark:text-red-400 dark:hover:text-red-300 gap-2"
diff --git a/appview/state/artifact.go b/appview/state/artifact.go
index 6caca705..2942ba62 100644
--- a/appview/state/artifact.go
+++ b/appview/state/artifact.go
@@ -23,7 +23,7 @@ import (
 func (s *State) AttachArtifact(w http.ResponseWriter, r *http.Request) {
 	user := s.auth.GetUser(r)
 	tagParam := chi.URLParam(r, "tag")
-	f, err := fullyResolvedRepo(r)
+	f, err := s.fullyResolvedRepo(r)
 	if err != nil {
 		log.Println("failed to get repo and knot", err)
 		s.pages.Notice(w, "upload", "failed to upload artifact, error in repo resolution")
@@ -98,7 +98,7 @@ func (s *State) AttachArtifact(w http.ResponseWriter, r *http.Request) {
 		BlobCid:   cid.Cid(uploadBlobResp.Blob.Ref),
 		Name:      handler.Filename,
 		Size:      uint64(uploadBlobResp.Blob.Size),
-		Mimetype:  uploadBlobResp.Blob.MimeType,
+		MimeType:  uploadBlobResp.Blob.MimeType,
 	}
 
 	err = db.AddArtifact(tx, artifact)
@@ -126,7 +126,7 @@ func (s *State) AttachArtifact(w http.ResponseWriter, r *http.Request) {
 func (s *State) DownloadArtifact(w http.ResponseWriter, r *http.Request) {
 	tagParam := chi.URLParam(r, "tag")
 	filename := chi.URLParam(r, "file")
-	f, err := fullyResolvedRepo(r)
+	f, err := s.fullyResolvedRepo(r)
 	if err != nil {
 		log.Println("failed to get repo and knot", err)
 		return
@@ -143,9 +143,9 @@ func (s *State) DownloadArtifact(w http.ResponseWriter, r *http.Request) {
 
 	artifacts, err := db.GetArtifact(
 		s.db,
-		db.NewFilter("repo_at", f.RepoAt),
-		db.NewFilter("tag", tag.Tag.Hash[:]),
-		db.NewFilter("name", filename),
+		db.Filter("repo_at", f.RepoAt),
+		db.Filter("tag", tag.Tag.Hash[:]),
+		db.Filter("name", filename),
 	)
 	if err != nil {
 		log.Println("failed to get artifacts", err)
@@ -173,7 +173,7 @@ func (s *State) DeleteArtifact(w http.ResponseWriter, r *http.Request) {
 	user := s.auth.GetUser(r)
 	tagParam := chi.URLParam(r, "tag")
 	filename := chi.URLParam(r, "file")
-	f, err := fullyResolvedRepo(r)
+	f, err := s.fullyResolvedRepo(r)
 	if err != nil {
 		log.Println("failed to get repo and knot", err)
 		return
@@ -185,9 +185,9 @@ func (s *State) DeleteArtifact(w http.ResponseWriter, r *http.Request) {
 
 	artifacts, err := db.GetArtifact(
 		s.db,
-		db.NewFilter("repo_at", f.RepoAt),
-		db.NewFilter("tag", tag[:]),
-		db.NewFilter("name", filename),
+		db.Filter("repo_at", f.RepoAt),
+		db.Filter("tag", tag[:]),
+		db.Filter("name", filename),
 	)
 	if err != nil {
 		log.Println("failed to get artifacts", err)
@@ -226,10 +226,10 @@ func (s *State) DeleteArtifact(w http.ResponseWriter, r *http.Request) {
 	}
 	defer tx.Rollback()
 
-	err = db.RemoveArtifact(tx,
-		db.NewFilter("repo_at", f.RepoAt),
-		db.NewFilter("tag", artifact.Tag[:]),
-		db.NewFilter("name", filename),
+	err = db.DeleteArtifact(tx,
+		db.Filter("repo_at", f.RepoAt),
+		db.Filter("tag", artifact.Tag[:]),
+		db.Filter("name", filename),
 	)
 	if err != nil {
 		log.Println("failed to remove artifact record from db", err)
diff --git a/appview/state/jetstream.go b/appview/state/jetstream.go
deleted file mode 100644
index 99bc0092..00000000
--- a/appview/state/jetstream.go
+++ /dev/null
@@ -1,70 +0,0 @@
-package state
-
-import (
-	"context"
-	"encoding/json"
-	"fmt"
-	"log"
-
-	"github.com/bluesky-social/indigo/atproto/syntax"
-	"github.com/bluesky-social/jetstream/pkg/models"
-	"tangled.sh/tangled.sh/core/api/tangled"
-	"tangled.sh/tangled.sh/core/appview/db"
-)
-
-type Ingester func(ctx context.Context, e *models.Event) error
-
-func jetstreamIngester(d db.DbWrapper) Ingester {
-	return func(ctx context.Context, e *models.Event) error {
-		var err error
-		defer func() {
-			eventTime := e.TimeUS
-			lastTimeUs := eventTime + 1
-			if err := d.SaveLastTimeUs(lastTimeUs); err != nil {
-				err = fmt.Errorf("(deferred) failed to save last time us: %w", err)
-			}
-		}()
-
-		if e.Kind != models.EventKindCommit {
-			return nil
-		}
-
-		did := e.Did
-		raw := json.RawMessage(e.Commit.Record)
-
-		switch e.Commit.Collection {
-		case tangled.GraphFollowNSID:
-			record := tangled.GraphFollow{}
-			err := json.Unmarshal(raw, &record)
-			if err != nil {
-				log.Println("invalid record")
-				return err
-			}
-			err = db.AddFollow(d, did, record.Subject, e.Commit.RKey)
-			if err != nil {
-				return fmt.Errorf("failed to add follow to db: %w", err)
-			}
-		case tangled.FeedStarNSID:
-			record := tangled.FeedStar{}
-			err := json.Unmarshal(raw, &record)
-			if err != nil {
-				log.Println("invalid record")
-				return err
-			}
-
-			subjectUri, err := syntax.ParseATURI(record.Subject)
-
-			if err != nil {
-				log.Println("invalid record")
-				return err
-			}
-
-			err = db.AddStar(d, did, subjectUri, e.Commit.RKey)
-			if err != nil {
-				return fmt.Errorf("failed to add follow to db: %w", err)
-			}
-		}
-
-		return err
-	}
-}
diff --git a/appview/state/repo.go b/appview/state/repo.go
index 93547e49..f0c69c4c 100644
--- a/appview/state/repo.go
+++ b/appview/state/repo.go
@@ -420,7 +420,7 @@ func (s *State) RepoTags(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
-	artifacts, err := db.GetArtifact(s.db, db.NewFilter("repo_at", f.RepoAt))
+	artifacts, err := db.GetArtifact(s.db, db.Filter("repo_at", f.RepoAt))
 	if err != nil {
 		log.Println("failed grab artifacts", err)
 		return
diff --git a/appview/state/state.go b/appview/state/state.go
index b676bd93..16284585 100644
--- a/appview/state/state.go
+++ b/appview/state/state.go
@@ -63,7 +63,7 @@ func Make(config *appview.Config) (*State, error) {
 	jc, err := jetstream.NewJetstreamClient(
 		config.JetstreamEndpoint,
 		"appview",
-		[]string{tangled.GraphFollowNSID, tangled.FeedStarNSID, tangled.PublicKeyNSID},
+		[]string{tangled.GraphFollowNSID, tangled.FeedStarNSID, tangled.PublicKeyNSID, tangled.RepoArtifactNSID},
 		nil,
 		slog.Default(),
 		wrapper,
diff --git a/flake.nix b/flake.nix
index 7b230351..8e88d551 100644
--- a/flake.nix
+++ b/flake.nix
@@ -49,7 +49,7 @@
     inherit (gitignore.lib) gitignoreSource;
   in {
     overlays.default = final: prev: let
-      goModHash = "sha256-EilWxfqrcKDaSR5zA3ZuDSCq7V+/IfWpKPu8HWhpndA=";
+      goModHash = "sha256-CmBuvv3duQQoc8iTW4244w1rYLGeqMQS+qQ3wwReZZg=";
       buildCmdPackage = name:
         final.buildGoModule {
           pname = name;