Compare commits
10 Commits
Author | SHA1 | Date | |
---|---|---|---|
49bb6cbaea | |||
38318f5dc6 | |||
db72c24de3 | |||
87170420e4 | |||
2e79ac4460 | |||
cd1f1d7b5f | |||
a3ee0b7900 | |||
114c7101d6 | |||
41476d04a2 | |||
a5780449fc |
@ -5,17 +5,17 @@
|
||||
tasks:
|
||||
- name: Copy build to remote
|
||||
ansible.builtin.copy:
|
||||
src: ../build/ev
|
||||
src: ../ev
|
||||
dest: /usr/local/bin/ev
|
||||
owner: root
|
||||
group: root
|
||||
|
||||
- name: Copy build to remote
|
||||
ansible.builtin.copy:
|
||||
src: ev.service
|
||||
dest: /etc/systemd/system/ev.service
|
||||
owner: root
|
||||
group: root
|
||||
# - name: Copy build to remote
|
||||
# ansible.builtin.copy:
|
||||
# src: ev.service
|
||||
# dest: /etc/systemd/system/ev.service
|
||||
# owner: root
|
||||
# group: root
|
||||
|
||||
- name: Restart service
|
||||
systemd:
|
||||
|
@ -9,12 +9,8 @@ on:
|
||||
jobs:
|
||||
deploy:
|
||||
runs-on: ubuntu-latest
|
||||
steps:
|
||||
steps:
|
||||
- uses: actions/checkout@v3
|
||||
with:
|
||||
fetch-depth: 0
|
||||
fetch-tags: true
|
||||
|
||||
- run: apt-get update && apt-get -y install ansible
|
||||
|
||||
- name: Set up Go
|
||||
@ -22,15 +18,17 @@ jobs:
|
||||
with:
|
||||
go-version: 1.21.1
|
||||
|
||||
- name: Build
|
||||
run: go build -ldflags "-s -w" -o ./build/ev ./cmd/ev
|
||||
- name: Install
|
||||
run: go install -ldflags "-s -w" go.sour.is/tools/cmd/ev@main
|
||||
|
||||
- run: mv $(go env GOPATH)/bin/ev ev
|
||||
|
||||
- name: Compress
|
||||
uses: https://git.sour.is/actions/ghaction-upx@v2.4.0
|
||||
with:
|
||||
version: latest
|
||||
files: |
|
||||
./build/ev
|
||||
./ev
|
||||
args: -fq
|
||||
|
||||
- name: Deploy
|
||||
|
1
.gitignore
vendored
1
.gitignore
vendored
@ -1 +1,2 @@
|
||||
tools
|
||||
sour.is-tools
|
||||
|
4
Makefile
4
Makefile
@ -1,6 +1,6 @@
|
||||
export PATH:=$(shell go env GOPATH)/bin:$(PATH)
|
||||
export EV_DATA=mem:
|
||||
export EV_HTTP=:8080
|
||||
export EV_HTTP=:8085
|
||||
export WEBFINGER_DOMAINS=localhost
|
||||
|
||||
.DEFAULT_GOAL := air
|
||||
@ -15,7 +15,7 @@ endif
|
||||
air .
|
||||
|
||||
run:
|
||||
go build . && ./tools
|
||||
go build -buildvcs=true -o sour.is-tools ./cmd/ev && ./sour.is-tools
|
||||
|
||||
test:
|
||||
go test -cover -race ./...
|
||||
|
@ -179,7 +179,7 @@ func (s *service) getPending(w http.ResponseWriter, r *http.Request, peerID stri
|
||||
return nil
|
||||
})
|
||||
if err != nil {
|
||||
span.RecordError(err)
|
||||
span.AddEvent(err.Error())
|
||||
w.WriteHeader(http.StatusNotFound)
|
||||
return
|
||||
}
|
||||
@ -204,8 +204,9 @@ func (s *service) getPending(w http.ResponseWriter, r *http.Request, peerID stri
|
||||
peerResults.SetStreamID(aggPeer(peerID))
|
||||
err = s.es.Load(ctx, peerResults)
|
||||
if err != nil && !errors.Is(err, ev.ErrNotFound) {
|
||||
span.RecordError(fmt.Errorf("peer not found: %w", err))
|
||||
span.AddEvent("peer not found")
|
||||
w.WriteHeader(http.StatusNotFound)
|
||||
return
|
||||
}
|
||||
|
||||
var req *Request
|
||||
@ -221,8 +222,9 @@ func (s *service) getPending(w http.ResponseWriter, r *http.Request, peerID stri
|
||||
}
|
||||
}
|
||||
if req == nil {
|
||||
span.RecordError(fmt.Errorf("request not found"))
|
||||
span.AddEvent("request not found")
|
||||
w.WriteHeader(http.StatusNoContent)
|
||||
return
|
||||
}
|
||||
|
||||
negotiator := contentnegotiation.NewNegotiator("application/json", "text/environment", "text/plain", "text/html")
|
||||
@ -304,7 +306,7 @@ func (s *service) getResults(w http.ResponseWriter, r *http.Request) {
|
||||
sort.Sort(sort.Reverse(requests))
|
||||
|
||||
args := requestArgs(r)
|
||||
args.Requests = requests[:maxResults]
|
||||
args.Requests = requests[:min(maxResults, len(requests))]
|
||||
|
||||
s.state.Use(ctx, func(ctx context.Context, state *state) error {
|
||||
args.CountPeers = len(state.peers)
|
||||
@ -433,8 +435,8 @@ func (s *service) postResult(w http.ResponseWriter, r *http.Request, reqID strin
|
||||
err := s.state.Use(ctx, func(ctx context.Context, state *state) error {
|
||||
var ok bool
|
||||
if _, ok = state.peers[peerID]; !ok {
|
||||
log.Printf("peer not found: %s\n", peerID)
|
||||
return fmt.Errorf("peer not found: %s", peerID)
|
||||
log.Printf("peer not found: req=%s peer=%s\n", reqID, peerID)
|
||||
return fmt.Errorf("peer not found: req=%s peer=%s", reqID, peerID)
|
||||
}
|
||||
|
||||
return nil
|
||||
@ -448,9 +450,10 @@ func (s *service) postResult(w http.ResponseWriter, r *http.Request, reqID strin
|
||||
peerResults := &PeerResults{}
|
||||
peerResults.SetStreamID(aggPeer(peerID))
|
||||
err = s.es.Load(ctx, peerResults)
|
||||
if err != nil {
|
||||
span.RecordError(fmt.Errorf("peer not found: %w", err))
|
||||
if err != nil && !errors.Is(err, ev.ErrNotFound) {
|
||||
span.RecordError(fmt.Errorf("peer not found: req=%s peer=%s %w", reqID, peerID, err))
|
||||
w.WriteHeader(http.StatusNotFound)
|
||||
return
|
||||
}
|
||||
|
||||
if peerResults.Has(reqID) {
|
||||
|
@ -91,17 +91,17 @@ func (s *service) Run(ctx context.Context) (err error) {
|
||||
subRes, e := s.es.EventStream().Subscribe(ctx, queueResults, 0)
|
||||
errs = multierr.Append(errs, e)
|
||||
|
||||
if errs != nil {
|
||||
return errs
|
||||
}
|
||||
|
||||
defer func() {
|
||||
ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
|
||||
defer cancel()
|
||||
|
||||
err = multierr.Combine(errs, subReq.Close(ctx), subRes.Close(ctx))
|
||||
err = multierr.Combine(err, subReq.Close(ctx), subRes.Close(ctx))
|
||||
}()
|
||||
|
||||
if errs != nil {
|
||||
return errs
|
||||
}
|
||||
|
||||
for {
|
||||
var events event.Events
|
||||
select {
|
||||
|
@ -4,10 +4,13 @@ import (
|
||||
"context"
|
||||
"errors"
|
||||
"log"
|
||||
"log/slog"
|
||||
"net/http"
|
||||
"os"
|
||||
"os/signal"
|
||||
"strconv"
|
||||
|
||||
"go.sour.is/pkg/env"
|
||||
"go.sour.is/pkg/lg"
|
||||
"go.sour.is/pkg/service"
|
||||
)
|
||||
@ -27,6 +30,13 @@ func main() {
|
||||
}
|
||||
}
|
||||
func run(ctx context.Context) error {
|
||||
// TODO: make this configurable.
|
||||
level := slog.LevelError
|
||||
if ok, _ := strconv.ParseBool(env.Default("LOG_DEBUG", "FALSE")); ok {
|
||||
level = slog.LevelDebug
|
||||
}
|
||||
slog.SetDefault(slog.New(slog.NewTextHandler(os.Stdout, &slog.HandlerOptions{Level: level})))
|
||||
|
||||
svc := &service.Harness{}
|
||||
ctx, stop := lg.Init(ctx, appName)
|
||||
svc.OnStop(stop)
|
||||
|
Loading…
x
Reference in New Issue
Block a user