Compare commits
5 Commits
v1.4.4-rc.
...
cache-erro
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
817b523135 | ||
| e0e3d9b6cf | |||
|
|
2cabae1e74
|
||
|
|
f949b83a51
|
||
|
|
d586c41cca
|
@@ -11,7 +11,7 @@ RUN apt-get update && apt-get install -y --no-install-recommends \
|
|||||||
libgdbm-dev \
|
libgdbm-dev \
|
||||||
git \
|
git \
|
||||||
&& rm -rf /var/lib/apt/lists/*
|
&& rm -rf /var/lib/apt/lists/*
|
||||||
RUN git clone https://git.defalsify.org/vise.git go-vise
|
RUN git clone https://github.com/nolash/go-vise go-vise
|
||||||
COPY . ./sarafu-vise
|
COPY . ./sarafu-vise
|
||||||
|
|
||||||
WORKDIR /build/sarafu-vise/services/registration
|
WORKDIR /build/sarafu-vise/services/registration
|
||||||
|
|||||||
@@ -79,11 +79,12 @@ func main() {
|
|||||||
pfp := path.Join(scriptDir, "pp.csv")
|
pfp := path.Join(scriptDir, "pp.csv")
|
||||||
|
|
||||||
cfg := engine.Config{
|
cfg := engine.Config{
|
||||||
Root: "root",
|
Root: "root",
|
||||||
OutputSize: uint32(size),
|
OutputSize: uint32(size),
|
||||||
FlagCount: uint32(128),
|
FlagCount: uint32(128),
|
||||||
MenuSeparator: menuSeparator,
|
MenuSeparator: menuSeparator,
|
||||||
ResetOnEmptyInput: true,
|
ResetOnEmptyInput: true,
|
||||||
|
ResetRoot: true, // clear the cache once a user quits
|
||||||
}
|
}
|
||||||
|
|
||||||
if engineDebug {
|
if engineDebug {
|
||||||
|
|||||||
@@ -94,11 +94,12 @@ func main() {
|
|||||||
pfp := path.Join(scriptDir, "pp.csv")
|
pfp := path.Join(scriptDir, "pp.csv")
|
||||||
|
|
||||||
cfg := engine.Config{
|
cfg := engine.Config{
|
||||||
Root: "root",
|
Root: "root",
|
||||||
OutputSize: uint32(size),
|
OutputSize: uint32(size),
|
||||||
FlagCount: uint32(128),
|
FlagCount: uint32(128),
|
||||||
MenuSeparator: menuSeparator,
|
MenuSeparator: menuSeparator,
|
||||||
ResetOnEmptyInput: true,
|
ResetOnEmptyInput: true,
|
||||||
|
ResetRoot: true, // clear the cache once a user quits
|
||||||
}
|
}
|
||||||
|
|
||||||
if engineDebug {
|
if engineDebug {
|
||||||
|
|||||||
@@ -82,6 +82,7 @@ func main() {
|
|||||||
MenuSeparator: menuSeparator,
|
MenuSeparator: menuSeparator,
|
||||||
EngineDebug: engineDebug,
|
EngineDebug: engineDebug,
|
||||||
ResetOnEmptyInput: true,
|
ResetOnEmptyInput: true,
|
||||||
|
ResetRoot: true, // clear the cache once a user quits
|
||||||
}
|
}
|
||||||
|
|
||||||
menuStorageService := storage.NewMenuStorageService(conns)
|
menuStorageService := storage.NewMenuStorageService(conns)
|
||||||
|
|||||||
@@ -4,6 +4,7 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"fmt"
|
"fmt"
|
||||||
"strconv"
|
"strconv"
|
||||||
|
"time"
|
||||||
|
|
||||||
"git.defalsify.org/vise.git/resource"
|
"git.defalsify.org/vise.git/resource"
|
||||||
"git.grassecon.net/grassrootseconomics/common/hex"
|
"git.grassecon.net/grassrootseconomics/common/hex"
|
||||||
@@ -411,7 +412,10 @@ func (h *MenuHandlers) InitiateGetMpesa(ctx context.Context, sym string, input [
|
|||||||
return res, nil
|
return res, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
logg.InfoCtxf(ctx, "poolSwap", "swapTrackingId", poolSwap.TrackingId)
|
logg.InfoCtxf(ctx, "mpesa poolSwap before transfer", "swapTrackingId", poolSwap.TrackingId)
|
||||||
|
|
||||||
|
// TODO: remove this temporary time delay and replace with a swap and send endpoint
|
||||||
|
time.Sleep(1 * time.Second)
|
||||||
|
|
||||||
finalKshStr, err := userStore.ReadEntry(ctx, sessionId, storedb.DATA_TEMPORARY_VALUE)
|
finalKshStr, err := userStore.ReadEntry(ctx, sessionId, storedb.DATA_TEMPORARY_VALUE)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
@@ -6,6 +6,7 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
|
"time"
|
||||||
|
|
||||||
"git.defalsify.org/vise.git/db"
|
"git.defalsify.org/vise.git/db"
|
||||||
"git.defalsify.org/vise.git/resource"
|
"git.defalsify.org/vise.git/resource"
|
||||||
@@ -842,7 +843,10 @@ func (h *MenuHandlers) TransactionInitiateSwap(ctx context.Context, sym string,
|
|||||||
}
|
}
|
||||||
|
|
||||||
swapTrackingId := poolSwap.TrackingId
|
swapTrackingId := poolSwap.TrackingId
|
||||||
logg.InfoCtxf(ctx, "poolSwap", "swapTrackingId", swapTrackingId)
|
logg.InfoCtxf(ctx, "send poolSwap before transfer", "swapTrackingId", swapTrackingId)
|
||||||
|
|
||||||
|
// TODO: remove this temporary time delay and replace with a swap and send endpoint
|
||||||
|
time.Sleep(1 * time.Second)
|
||||||
|
|
||||||
// Initiate a send
|
// Initiate a send
|
||||||
recipientPublicKey, err := userStore.ReadEntry(ctx, sessionId, storedb.DATA_RECIPIENT)
|
recipientPublicKey, err := userStore.ReadEntry(ctx, sessionId, storedb.DATA_RECIPIENT)
|
||||||
@@ -874,7 +878,7 @@ func (h *MenuHandlers) TransactionInitiateSwap(ctx context.Context, sym string,
|
|||||||
}
|
}
|
||||||
|
|
||||||
trackingId := tokenTransfer.TrackingId
|
trackingId := tokenTransfer.TrackingId
|
||||||
logg.InfoCtxf(ctx, "TokenTransfer", "trackingId", trackingId)
|
logg.InfoCtxf(ctx, "send TokenTransfer after swap", "trackingId", trackingId)
|
||||||
|
|
||||||
res.Content = l.Get(
|
res.Content = l.Get(
|
||||||
"Your request has been sent. %s will receive %s %s from %s.",
|
"Your request has been sent. %s will receive %s %s from %s.",
|
||||||
|
|||||||
Reference in New Issue
Block a user