commit 01942291458d62d6ac3782147859ec644dd49bbd · kot.pink/core

+1 -1

appview/db/jetstream.go

···

       1
       1
        
       package db

     

       2
       2
        
       

     

       3
       3
        
       func (d *DB) SaveLastTimeUs(lastTimeUs int64) error {

     

       4
       4
       -
       	_, err := d.db.Exec(`insert into _jetstream (last_time_us) values (?)`, lastTimeUs)

     

       4
       4
       +
       	_, err := d.db.Exec(`update _jetstream set last_time_us = ?`, lastTimeUs)

     

       5
       5
        
       	return err

     

       6
       6
        
       }

     

       7
       7

+1 -1

knotserver/config/config.go

···

       14
       14
        
       

     

       15
       15
        
       type Server struct {

     

       16
       16
        
       	ListenAddr         string `env:"LISTEN_ADDR, default=0.0.0.0:5555"`

     

       17
       17
       -
       	InternalListenAddr string `env:"INTERNAL_LISTEN_ADDR, default=0.0.0.0:5444"`

     

       17
       17
       +
       	InternalListenAddr string `env:"INTERNAL_LISTEN_ADDR, default=127.0.0.1:5444"`

     

       18
       18
        
       	Secret             string `env:"SECRET, required"`

     

       19
       19
        
       	DBPath             string `env:"DB_PATH, default=knotserver.db"`

     

       20
       20
        
       	Hostname           string `env:"HOSTNAME, required"`

+1 -1

knotserver/db/jetstream.go

···

       1
       1
        
       package db

     

       2
       2
        
       

     

       3
       3
        
       func (d *DB) SaveLastTimeUs(lastTimeUs int64) error {

     

       4
       4
       -
       	_, err := d.db.Exec(`insert into _jetstream (last_time_us) values (?)`, lastTimeUs)

     

       4
       4
       +
       	_, err := d.db.Exec(`update _jetstream set last_time_us = ?`, lastTimeUs)

     

       5
       5
        
       	return err

     

       6
       6
        
       }

     

       7
       7

+1 -1

knotserver/routes.go

···

       26
       26
        
       )

     

       27
       27
        
       

     

       28
       28
        
       func (h *Handle) Index(w http.ResponseWriter, r *http.Request) {

     

       29
       29
       -
       	w.Write([]byte("This is a knot, part of the wider Tangle network: https://tangled.sh"))

     

       29
       29
       +
       	w.Write([]byte("This is a knot server. More info at https://tangled.sh"))

     

       30
       30
        
       }

     

       31
       31
        
       

     

       32
       32
        
       func (h *Handle) RepoIndex(w http.ResponseWriter, r *http.Request) {