Compare commits
7 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 41476d04a2 | |||
| a5780449fc | |||
| 4784c1c380 | |||
| 6bb1d524b9 | |||
| bcadac0f07 | |||
| 1a2087f2ee | |||
| f2069de1ec |
@@ -5,7 +5,7 @@ After=syslog.target network.target
|
||||
[Service]
|
||||
Type=simple
|
||||
ExecStart=/usr/local/bin/ev
|
||||
|
||||
User=www-data
|
||||
Restart=always
|
||||
RestartSec=30
|
||||
|
||||
|
||||
@@ -10,12 +10,12 @@
|
||||
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:
|
||||
|
||||
@@ -20,7 +20,6 @@ jobs:
|
||||
|
||||
- run: go install github.com/psanetra/git-semver/cli@master
|
||||
|
||||
- run: git tag v$(cli next --stable=false)
|
||||
- run: git push --tags
|
||||
- run: git tag v$(cli next --stable=false) && git push --tags || echo no change
|
||||
|
||||
- run: echo "🍏 This job's status is ${{ job.status }}."
|
||||
|
||||
@@ -1,12 +1,10 @@
|
||||
name: Deploy
|
||||
|
||||
on:
|
||||
# push:
|
||||
# branches: [ "main" ]
|
||||
push:
|
||||
branches: [ "main" ]
|
||||
release:
|
||||
types: [ published ]
|
||||
create:
|
||||
types: [ tag ]
|
||||
|
||||
jobs:
|
||||
deploy:
|
||||
|
||||
@@ -304,7 +304,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)
|
||||
|
||||
@@ -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(subReq.Close(ctx), subRes.Close(ctx), err)
|
||||
err = multierr.Combine(err, subReq.Close(ctx), subRes.Close(ctx))
|
||||
}()
|
||||
|
||||
if errs != nil {
|
||||
return errs
|
||||
}
|
||||
|
||||
for {
|
||||
var events event.Events
|
||||
select {
|
||||
|
||||
Reference in New Issue
Block a user