patch of appview/repo: display pipeline status on repo index · round #0 · pull #254 · tangled.org/core

+47

appview/pages/funcmap.go

···

       49
        
       		"sub": func(a, b int) int {

     

       50
        
       			return a - b

     

       51
        
       		},

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       52
        
       		"cond": func(cond interface{}, a, b string) string {

     

       53
        
       			if cond == nil {

     

       54
        
       				return b

     
···

       105
        
       				{math.MaxInt64, "a long while %s", 1},

     

       106
        
       			})

     

       107
        
       		},

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       108
        
       		"byteFmt": humanize.Bytes,

     

       109
        
       		"length": func(slice any) int {

     

       110
        
       			v := reflect.ValueOf(slice)

···

       49
        
       		"sub": func(a, b int) int {

     

       50
        
       			return a - b

     

       51
        
       		},

     

       52
       +
       		"f64": func(a int) float64 {

     

       53
       +
       			return float64(a)

     

       54
       +
       		},

     

       55
       +
       		"addf64": func(a, b float64) float64 {

     

       56
       +
       			return a + b

     

       57
       +
       		},

     

       58
       +
       		"subf64": func(a, b float64) float64 {

     

       59
       +
       			return a - b

     

       60
       +
       		},

     

       61
       +
       		"mulf64": func(a, b float64) float64 {

     

       62
       +
       			return a * b

     

       63
       +
       		},

     

       64
       +
       		"divf64": func(a, b float64) float64 {

     

       65
       +
       			if b == 0 {

     

       66
       +
       				return 0

     

       67
       +
       			}

     

       68
       +
       			return a / b

     

       69
       +
       		},

     

       70
       +
       		"negf64": func(a float64) float64 {

     

       71
       +
       			return -a

     

       72
       +
       		},

     

       73
        
       		"cond": func(cond interface{}, a, b string) string {

     

       74
        
       			if cond == nil {

     

       75
        
       				return b

     
···

       126
        
       				{math.MaxInt64, "a long while %s", 1},

     

       127
        
       			})

     

       128
        
       		},

     

       129
       +
       		"durationFmt": func(duration time.Duration) string {

     

       130
       +
       			days := int64(duration.Hours() / 24)

     

       131
       +
       			hours := int64(math.Mod(duration.Hours(), 24))

     

       132
       +
       			minutes := int64(math.Mod(duration.Minutes(), 60))

     

       133
       +
       			seconds := int64(math.Mod(duration.Seconds(), 60))

     

       134
       +
       

     

       135
       +
       			chunks := []struct {

     

       136
       +
       				name   string

     

       137
       +
       				amount int64

     

       138
       +
       			}{

     

       139
       +
       				{"d", days},

     

       140
       +
       				{"hr", hours},

     

       141
       +
       				{"min", minutes},

     

       142
       +
       				{"s", seconds},

     

       143
       +
       			}

     

       144
       +
       

     

       145
       +
       			parts := []string{}

     

       146
       +
       

     

       147
       +
       			for _, chunk := range chunks {

     

       148
       +
       				if chunk.amount != 0 {

     

       149
       +
       					parts = append(parts, fmt.Sprintf("%d%s", chunk.amount, chunk.name))

     

       150
       +
       				}

     

       151
       +
       			}

     

       152
       +
       

     

       153
       +
       			return strings.Join(parts, " ")

     

       154
       +
       		},

     

       155
        
       		"byteFmt": humanize.Bytes,

     

       156
        
       		"length": func(slice any) int {

     

       157
        
       			v := reflect.ValueOf(slice)

appview/pages/pages.go

···

       436
        
       	EmailToDidOrHandle map[string]string

     

       437
        
       	VerifiedCommits    commitverify.VerifiedCommits

     

       438
        
       	Languages          *types.RepoLanguageResponse

     

       0
        
       
     

       439
        
       	types.RepoIndexResponse

     

       440
        
       }

     

       441

···

       436
        
       	EmailToDidOrHandle map[string]string

     

       437
        
       	VerifiedCommits    commitverify.VerifiedCommits

     

       438
        
       	Languages          *types.RepoLanguageResponse

     

       439
       +
       	Pipelines          map[plumbing.Hash]db.Pipeline

     

       440
        
       	types.RepoIndexResponse

     

       441
        
       }

     

       442

+118

appview/pages/templates/repo/fragments/pipelineStatusSymbol.html

···

       1
       +
       {{ define "repo/fragments/pipelineStatusSymbol" }}

     

       2
       +
         <div class="group relative inline-block">

     

       3
       +
           {{ block "icon" $ }} {{ end }}

     

       4
       +
           {{ block "tooltip" $ }} {{ end }}

     

       5
       +
         </div>

     

       6
       +
       {{ end }}

     

       7
       +
       

     

       8
       +
       {{ define "icon" }}

     

       9
       +
       <div class="cursor-pointer">

     

       10
       +
         {{ $c := .Counts }}

     

       11
       +
         {{ $statuses := .Statuses }}

     

       12
       +
         {{ $total := len $statuses }}

     

       13
       +
         {{ $success := index $c "success" }}

     

       14
       +
         {{ $allPass := eq $success $total }}

     

       15
       +
       

     

       16
       +
         {{ if $allPass }}

     

       17
       +
           <div class="flex gap-1 items-center">

     

       18
       +
             {{ i "check" "size-4 text-green-600 dark:text-green-400 " }} {{ $total }}/{{ $total }}

     

       19
       +
           </div>

     

       20
       +
         {{ else }}

     

       21
       +
           {{ $radius := f64 8 }}

     

       22
       +
           {{ $circumference := mulf64 2.0 (mulf64 3.1416 $radius) }}

     

       23
       +
           {{ $offset := 0.0 }}

     

       24
       +
           <div class="flex gap-1 items-center">

     

       25
       +
             <svg class="w-4 h-4 transform -rotate-90" viewBox="0 0 20 20">

     

       26
       +
               <circle cx="10" cy="10" r="{{ $radius }}" fill="none" stroke="#f3f4f633" stroke-width="2"/>

     

       27
       +
       

     

       28
       +
               {{ range $kind, $count := $c }}

     

       29
       +
                 {{ $color := "" }}

     

       30
       +
                 {{ if or (eq $kind "pending") (eq $kind "running") }}

     

       31
       +
                   {{ $color = "#eab308" }}

     

       32
       +
                 {{ else if eq $kind "success" }}

     

       33
       +
                   {{ $color = "#10b981" }}

     

       34
       +
                 {{ else if eq $kind "cancelled" }}

     

       35
       +
                   {{ $color = "#6b7280" }}

     

       36
       +
                 {{ else }}

     

       37
       +
                   {{ $color = "#ef4444" }}

     

       38
       +
                 {{ end }}

     

       39
       +
       

     

       40
       +
                 {{ $percent := divf64 (f64 $count) (f64 $total) }}

     

       41
       +
                 {{ $length := mulf64 $percent $circumference }}

     

       42
       +
       

     

       43
       +
                 <circle

     

       44
       +
                   cx="10" cy="10" r="{{ $radius }}"

     

       45
       +
                   fill="none"

     

       46
       +
                   stroke="{{ $color }}"

     

       47
       +
                   stroke-width="2"

     

       48
       +
                   stroke-dasharray="{{ printf "%.2f %.2f" $length (subf64 $circumference $length) }}"

     

       49
       +
                   stroke-dashoffset="{{ printf "%.2f" (negf64 $offset) }}"

     

       50
       +
                 />

     

       51
       +
                 {{ $offset = addf64 $offset $length }}

     

       52
       +
               {{ end }}

     

       53
       +
             </svg>

     

       54
       +
             <span>{{$success}}/{{ $total }}</span>

     

       55
       +
           </div>

     

       56
       +
         {{ end }}

     

       57
       +
       </div>

     

       58
       +
       {{ end }}

     

       59
       +
       

     

       60
       +
       {{ define "tooltip" }}

     

       61
       +
       <div class="absolute z-[9999] hidden group-hover:block bg-white dark:bg-gray-900 text-sm text-black dark:text-white rounded-md shadow p-2 w-80 top-full mt-2">

     

       62
       +
         <div class="flex flex-col divide-y divide-gray-200 dark:divide-gray-700">

     

       63
       +
           {{ range $name, $all := .Statuses }}

     

       64
       +
           <div class="flex items-center justify-between p-1">

     

       65
       +
             {{ $lastStatus := $all.Latest }}

     

       66
       +
             {{ $kind := $lastStatus.Status.String }}

     

       67
       +
       

     

       68
       +
             {{ $icon := "dot" }}

     

       69
       +
             {{ $color := "text-gray-600 dark:text-gray-500" }}

     

       70
       +
             {{ $text := "Failed" }}

     

       71
       +
             {{ $time := "" }}

     

       72
       +
       

     

       73
       +
             {{ if eq $kind "pending" }}

     

       74
       +
               {{ $icon = "circle-dashed" }}

     

       75
       +
               {{ $color = "text-yellow-600 dark:text-yellow-500" }}

     

       76
       +
               {{ $text = "Queued" }}

     

       77
       +
               {{ $time = timeFmt $lastStatus.Created }}

     

       78
       +
             {{ else if eq $kind "running" }}

     

       79
       +
               {{ $icon = "circle-dashed" }}

     

       80
       +
               {{ $color = "text-yellow-600 dark:text-yellow-500" }}

     

       81
       +
               {{ $text = "Running" }}

     

       82
       +
               {{ $time = timeFmt $lastStatus.Created }}

     

       83
       +
             {{ else if eq $kind "success" }}

     

       84
       +
               {{ $icon = "check" }}

     

       85
       +
               {{ $color = "text-green-600 dark:text-green-500" }}

     

       86
       +
               {{ $text = "Success" }}

     

       87
       +
               {{ with $all.TimeTaken }}

     

       88
       +
                 {{ $time = durationFmt . }}

     

       89
       +
               {{ end }}

     

       90
       +
             {{ else if eq $kind "cancelled" }}

     

       91
       +
               {{ $icon = "circle-slash" }}

     

       92
       +
               {{ $color = "text-gray-600 dark:text-gray-500" }}

     

       93
       +
               {{ $text = "Cancelled" }}

     

       94
       +
               {{ with $all.TimeTaken }}

     

       95
       +
                 {{ $time = durationFmt . }}

     

       96
       +
               {{ end }}

     

       97
       +
             {{ else }}

     

       98
       +
               {{ $icon = "x" }}

     

       99
       +
               {{ $color = "text-red-600 dark:text-red-500" }}

     

       100
       +
               {{ $text = "Failed" }}

     

       101
       +
               {{ with $all.TimeTaken }}

     

       102
       +
                 {{ $time = durationFmt . }}

     

       103
       +
               {{ end }}

     

       104
       +
             {{ end }}

     

       105
       +
       

     

       106
       +
             <div id="left" class="flex items-center gap-2 flex-shrink-0">

     

       107
       +
               {{ i $icon "size-4" $color }}

     

       108
       +
               {{ $name }}

     

       109
       +
             </div>

     

       110
       +
             <div id="right" class="flex items-center gap-2 flex-shrink-0">

     

       111
       +
               <span class="font-bold">{{ $text }}</span>

     

       112
       +
               <time class="text-gray-400 dark:text-gray-600">{{ $time }}</time>

     

       113
       +
             </div>

     

       114
       +
           </div>

     

       115
       +
           {{ end }}

     

       116
       +
         </div>

     

       117
       +
       </div>

     

       118
       +
       {{ end }}

+22 -18

appview/pages/templates/repo/index.html

···

       222
        
               </div>

     

       223
        
             </div>

     

       224
        
       

     

       0
        
       
     

       225
        
             <div class="text-xs mt-2 text-gray-500 dark:text-gray-400 flex items-center">

     

       226
        
                 {{ $verified := $.VerifiedCommits.IsVerified .Hash.String }}

     

       227
        
                 {{ $hashStyle := "text-gray-700 dark:text-gray-300 bg-gray-100 dark:bg-gray-900" }}

     
···

       238
        
                     </a>

     

       239
        
                 </span>

     

       240
        
               <span

     

       241
       -
                 class="mx-2 before:content-['·'] before:select-none"

     

       242
        
                 ></span>

     

       243
        
               <span>

     

       244
        
                 {{ $didOrHandle := index $.EmailToDidOrHandle .Author.Email }}

     
···

       256
        
                   {{ end }}</a

     

       257
        
                 >

     

       258
        
               </span>

     

       259
       -
                   <div

     

       260
       -
                     class="inline-block px-1 select-none after:content-['·']"

     

       261
       -
                     ></div>

     

       262
       -
                   <span>{{ timeFmt .Committer.When }}</span>

     

       263
       -
                   {{ $tagsForCommit := index $.TagMap .Hash.String }}

     

       264
       -
                   {{ if gt (len $tagsForCommit) 0 }}

     

       265
       -
                   <div

     

       266
       -
                     class="inline-block px-1 select-none after:content-['·']"

     

       267
       -
                     ></div>

     

       268
       -
                   {{ end }}

     

       269
       -
                   {{ range $tagsForCommit }}

     

       270
       -
                   <span

     

       271
       -
                     class="text-xs rounded bg-gray-100 dark:bg-gray-700 text-black dark:text-white font-mono px-2 mx-1/2 inline-flex items-center"

     

       272
       -
                     >

     

       273
       -
                     {{ . }}

     

       274
       -
                   </span>

     

       275
       -
                     {{ end }}

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       276
        
             </div>

     

       277
        
           </div>

     

       278
        
           {{ end }}

···

       222
        
               </div>

     

       223
        
             </div>

     

       224
        
       

     

       225
       +
             <!-- commit info bar -->

     

       226
        
             <div class="text-xs mt-2 text-gray-500 dark:text-gray-400 flex items-center">

     

       227
        
                 {{ $verified := $.VerifiedCommits.IsVerified .Hash.String }}

     

       228
        
                 {{ $hashStyle := "text-gray-700 dark:text-gray-300 bg-gray-100 dark:bg-gray-900" }}

     
···

       239
        
                     </a>

     

       240
        
                 </span>

     

       241
        
               <span

     

       242
       +
                 class="mx-1 before:content-['·'] before:select-none"

     

       243
        
                 ></span>

     

       244
        
               <span>

     

       245
        
                 {{ $didOrHandle := index $.EmailToDidOrHandle .Author.Email }}

     
···

       257
        
                   {{ end }}</a

     

       258
        
                 >

     

       259
        
               </span>

     

       260
       +
               <div class="inline-block px-1 select-none after:content-['·']"></div>

     

       261
       +
               <span>{{ timeFmt .Committer.When }}</span>

     

       262
       +
       

     

       263
       +
               <!-- tags/branches -->

     

       264
       +
               {{ $tagsForCommit := index $.TagMap .Hash.String }}

     

       265
       +
               {{ if gt (len $tagsForCommit) 0 }}

     

       266
       +
                 <div class="inline-block px-1 select-none after:content-['·']"></div>

     

       267
       +
               {{ end }}

     

       268
       +
               {{ range $tagsForCommit }}

     

       269
       +
                 <span class="text-xs rounded bg-gray-100 dark:bg-gray-700 text-black dark:text-white font-mono px-2 mx-[2px] inline-flex items-center">

     

       270
       +
                   {{ . }}

     

       271
       +
                 </span>

     

       272
       +
               {{ end }}

     

       273
       +
       

     

       274
       +
               <!-- ci status -->

     

       275
       +
               {{ $pipeline := index $.Pipelines .Hash }}

     

       276
       +
               {{ if and $pipeline (gt (len $pipeline.Statuses) 0) }}

     

       277
       +
                 <div class="inline-block px-1 select-none after:content-['·']"></div>

     

       278
       +
                 {{ template "repo/fragments/pipelineStatusSymbol" $pipeline }}

     

       279
       +
               {{ end }}

     

       280
        
             </div>

     

       281
        
           </div>

     

       282
        
           {{ end }}

appview/repo/index.go

···

       127
        
       		// non-fatal

     

       128
        
       	}

     

       129
        
       

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       130
        
       	rp.pages.RepoIndexPage(w, pages.RepoIndexParams{

     

       131
        
       		LoggedInUser:       user,

     

       132
        
       		RepoInfo:           repoInfo,

     
···

       139
        
       		EmailToDidOrHandle: emailToDidOrHandle(rp, emailToDidMap),

     

       140
        
       		VerifiedCommits:    vc,

     

       141
        
       		Languages:          repoLanguages,

     

       0
        
       
     

       142
        
       	})

     

       143
        
       	return

     

       144
        
       }

···

       127
        
       		// non-fatal

     

       128
        
       	}

     

       129
        
       

     

       130
       +
       	pipelines, err := rp.getPipelineStatuses(repoInfo, commitsTrunc)

     

       131
       +
       	if err != nil {

     

       132
       +
       		log.Printf("failed to fetch pipeline statuses: %s", err)

     

       133
       +
       		// non-fatal

     

       134
       +
       	}

     

       135
       +
       

     

       136
        
       	rp.pages.RepoIndexPage(w, pages.RepoIndexParams{

     

       137
        
       		LoggedInUser:       user,

     

       138
        
       		RepoInfo:           repoInfo,

     
···

       145
        
       		EmailToDidOrHandle: emailToDidOrHandle(rp, emailToDidMap),

     

       146
        
       		VerifiedCommits:    vc,

     

       147
        
       		Languages:          repoLanguages,

     

       148
       +
       		Pipelines:          pipelines,

     

       149
        
       	})

     

       150
        
       	return

     

       151
        
       }

+41

appview/repo/repo_util.go

···

       6
        
       	"fmt"

     

       7
        
       	"math/big"

     

       8
        
       

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       9
        
       	"github.com/go-git/go-git/v5/plumbing/object"

     

       10
        
       )

     

       11
        
       

     
···

       98
        
       

     

       99
        
       	return string(result)

     

       100
        
       }

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0

···

       6
        
       	"fmt"

     

       7
        
       	"math/big"

     

       8
        
       

     

       9
       +
       	"tangled.sh/tangled.sh/core/appview/db"

     

       10
       +
       	"tangled.sh/tangled.sh/core/appview/pages/repoinfo"

     

       11
       +
       

     

       12
       +
       	"github.com/go-git/go-git/v5/plumbing"

     

       13
        
       	"github.com/go-git/go-git/v5/plumbing/object"

     

       14
        
       )

     

       15
        
       

     
···

       102
        
       

     

       103
        
       	return string(result)

     

       104
        
       }

     

       105
       +
       

     

       106
       +
       // grab pipelines from DB and munge that into a hashmap with commit sha as key

     

       107
       +
       //

     

       108
       +
       // golang is so blessed that it requires 35 lines of imperative code for this

     

       109
       +
       func (rp *Repo) getPipelineStatuses(

     

       110
       +
       	repoInfo repoinfo.RepoInfo,

     

       111
       +
       	commits []*object.Commit,

     

       112
       +
       ) (map[plumbing.Hash]db.Pipeline, error) {

     

       113
       +
       	m := make(map[plumbing.Hash]db.Pipeline)

     

       114
       +
       

     

       115
       +
       	if len(commits) == 0 {

     

       116
       +
       		return m, nil

     

       117
       +
       	}

     

       118
       +
       

     

       119
       +
       	shas := make([]string, len(commits))

     

       120
       +
       	for _, c := range commits {

     

       121
       +
       		shas = append(shas, c.Hash.String())

     

       122
       +
       	}

     

       123
       +
       

     

       124
       +
       	ps, err := db.GetPipelineStatuses(

     

       125
       +
       		rp.db,

     

       126
       +
       		db.FilterEq("repo_owner", repoInfo.OwnerDid),

     

       127
       +
       		db.FilterEq("repo_name", repoInfo.Name),

     

       128
       +
       		db.FilterEq("knot", repoInfo.Knot),

     

       129
       +
       		db.FilterIn("sha", shas),

     

       130
       +
       	)

     

       131
       +
       	if err != nil {

     

       132
       +
       		return nil, err

     

       133
       +
       	}

     

       134
       +
       

     

       135
       +
       	for _, p := range ps {

     

       136
       +
       		hash := plumbing.NewHash(p.Sha)

     

       137
       +
       		m[hash] = p

     

       138
       +
       	}

     

       139
       +
       

     

       140
       +
       	return m, nil

     

       141
       +
       }

+11 -3

appview/state/spindlestream.go

···

       4
        
       	"context"

     

       5
        
       	"encoding/json"

     

       6
        
       	"log/slog"

     

       0
        
       
     

       7
        
       	"time"

     

       8
        
       

     

       9
        
       	"github.com/bluesky-social/indigo/atproto/syntax"

     
···

       15
        
       	"tangled.sh/tangled.sh/core/eventconsumer/cursor"

     

       16
        
       	"tangled.sh/tangled.sh/core/log"

     

       17
        
       	"tangled.sh/tangled.sh/core/rbac"

     

       0
        
       
     

       18
        
       )

     

       19
        
       

     

       20
        
       func Spindlestream(ctx context.Context, c *config.Config, d *db.DB, enforcer *rbac.Enforcer) (*ec.Consumer, error) {

     
···

       77
        
       		exitCode = int(*record.ExitCode)

     

       78
        
       	}

     

       79
        
       

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       80
        
       	status := db.PipelineStatus{

     

       81
        
       		Spindle:      source.Key(),

     

       82
        
       		Rkey:         msg.Rkey,

     

       83
       -
       		PipelineKnot: pipelineUri.Authority().String(),

     

       84
        
       		PipelineRkey: pipelineUri.RecordKey().String(),

     

       85
       -
       		Created:      time.Now(),

     

       86
        
       		Workflow:     record.Workflow,

     

       87
       -
       		Status:       record.Status,

     

       88
        
       		Error:        record.Error,

     

       89
        
       		ExitCode:     exitCode,

     

       90
        
       	}

···

       4
        
       	"context"

     

       5
        
       	"encoding/json"

     

       6
        
       	"log/slog"

     

       7
       +
       	"strings"

     

       8
        
       	"time"

     

       9
        
       

     

       10
        
       	"github.com/bluesky-social/indigo/atproto/syntax"

     
···

       16
        
       	"tangled.sh/tangled.sh/core/eventconsumer/cursor"

     

       17
        
       	"tangled.sh/tangled.sh/core/log"

     

       18
        
       	"tangled.sh/tangled.sh/core/rbac"

     

       19
       +
       	spindle "tangled.sh/tangled.sh/core/spindle/models"

     

       20
        
       )

     

       21
        
       

     

       22
        
       func Spindlestream(ctx context.Context, c *config.Config, d *db.DB, enforcer *rbac.Enforcer) (*ec.Consumer, error) {

     
···

       79
        
       		exitCode = int(*record.ExitCode)

     

       80
        
       	}

     

       81
        
       

     

       82
       +
       	// pick the record creation time if possible, or use time.Now

     

       83
       +
       	created := time.Now()

     

       84
       +
       	if t, err := time.Parse(time.RFC3339, record.CreatedAt); err == nil && created.After(t) {

     

       85
       +
       		created = t

     

       86
       +
       	}

     

       87
       +
       

     

       88
        
       	status := db.PipelineStatus{

     

       89
        
       		Spindle:      source.Key(),

     

       90
        
       		Rkey:         msg.Rkey,

     

       91
       +
       		PipelineKnot: strings.TrimPrefix(pipelineUri.Authority().String(), "did:web:"),

     

       92
        
       		PipelineRkey: pipelineUri.RecordKey().String(),

     

       93
       +
       		Created:      created,

     

       94
        
       		Workflow:     record.Workflow,

     

       95
       +
       		Status:       spindle.StatusKind(record.Status),

     

       96
        
       		Error:        record.Error,

     

       97
        
       		ExitCode:     exitCode,

     

       98
        
       	}