appview/{db,models}: use pipeline at-uri for indexing

avoid using `.Knot` and `.Rkey` directly

Signed-off-by: Seongmin Lee <[e-mail]>

appview/db/pipeline.go

···
 	"strings"
 	"time"
 
+	"github.com/bluesky-social/indigo/atproto/syntax"
 	"tangled.org/core/appview/models"
 	"tangled.org/core/orm"
 )
···
 	}
 	defer rows.Close()
 
-	pipelines := make(map[string]models.Pipeline)
+	pipelines := make(map[syntax.ATURI]models.Pipeline)
 	for rows.Next() {
 		var p models.Pipeline
 		var t models.Trigger
···
 		p.Trigger = &t
 		p.Statuses = make(map[string]models.WorkflowStatus)
 
-		k := fmt.Sprintf("%s/%s", p.Knot, p.Rkey)
-		pipelines[k] = p
+		pipelines[p.AtUri()] = p
 	}
 
 	// get all statuses
···
 			return nil, fmt.Errorf("invalid status created timestamp %q: %w", created, err)
 		}
 
-		key := fmt.Sprintf("%s/%s", ps.PipelineKnot, ps.PipelineRkey)
+		pipelineAt := ps.PipelineAt()
 
 		// extract
-		pipeline, ok := pipelines[key]
+		pipeline, ok := pipelines[pipelineAt]
 		if !ok {
 			continue
 		}
···
 
 		// reassign
 		pipeline.Statuses[ps.Workflow] = statuses
-		pipelines[key] = pipeline
+		pipelines[pipelineAt] = pipeline
 	}
 
 	var all []models.Pipeline

appview/models/pipeline.go

···
 package models
 
 import (
+	"fmt"
 	"slices"
 	"time"
 
 	"github.com/bluesky-social/indigo/atproto/syntax"
 	"github.com/go-git/go-git/v5/plumbing"
+	"tangled.org/core/api/tangled"
 	spindle "tangled.org/core/spindle/models"
 	"tangled.org/core/workflow"
 )
···
 	// populate when querying for reverse mappings
 	Trigger  *Trigger
 	Statuses map[string]WorkflowStatus
+}
+
+func (p *Pipeline) AtUri() syntax.ATURI {
+	return syntax.ATURI(fmt.Sprintf("at://did:web:%s/%s/%s", p.Knot, tangled.PipelineNSID, p.Rkey))
 }
 
 type WorkflowStatus struct {
···
 	Error        *string
 	ExitCode     int
 }
+
+func (ps *PipelineStatus) PipelineAt() syntax.ATURI {
+	return syntax.ATURI(fmt.Sprintf("at://did:web:%s/%s/%s", ps.PipelineKnot, tangled.PipelineNSID, ps.PipelineRkey))
+}