Compare commits
35 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 01d56ca451 | |||
| b4af8d1876 | |||
| 69c8d0fe9c | |||
| bf1a6684a7 | |||
| 5a47ebae2b | |||
| 9d62f15b8f | |||
| 5524ea7878 | |||
| 3d1850b2d2 | |||
| 02283d57ba | |||
| 1768a48e5e | |||
| 1cdf825bcb | |||
| 71c86e512d | |||
| 9d8013bc33 | |||
| 05733d3b7a | |||
| 71c071bbdd | |||
| 1241fee61d | |||
| d64cb886c9 | |||
| ac8149e6bb | |||
| 493b61465b | |||
| df372e9cfd | |||
| ff58f3ae82 | |||
| b71db96b47 | |||
| 02434419f4 | |||
| bd096dc61f | |||
| 9f286f3121 | |||
| 2211f4f39d | |||
| a6b988df3a | |||
| 1316d3fb1e | |||
| 99fa75a980 | |||
| 6fc590d795 | |||
| 7afc804586 | |||
| f40692dd3d | |||
| 1c91699bf5 | |||
| 9f5e1e0853 | |||
| 55dfea65b0 |
@@ -53,8 +53,10 @@ jobs:
|
|||||||
run: |
|
run: |
|
||||||
TAGS="$(curl -s -u "${{ secrets.REGISTRY_USER }}:${{ secrets.REGISTRY_PASS }}" https://${{ secrets.REGISTRY_PATH }}/v2/umbrella/tags/list | jq -r ".tags[]")"
|
TAGS="$(curl -s -u "${{ secrets.REGISTRY_USER }}:${{ secrets.REGISTRY_PASS }}" https://${{ secrets.REGISTRY_PATH }}/v2/umbrella/tags/list | jq -r ".tags[]")"
|
||||||
COUNT=$(echo "$TAGS" | wc -l)
|
COUNT=$(echo "$TAGS" | wc -l)
|
||||||
|
echo found $COUNT tags: $TAGS
|
||||||
if [ $COUNT -gt 10 ]; then
|
if [ $COUNT -gt 10 ]; then
|
||||||
REMAIN=$((COUNT - 10))
|
REMAIN=$((COUNT - 10))
|
||||||
|
echo $REMAIN tags will be kept!
|
||||||
echo "$TAGS" | head -n $REMAIN > /tmp/old_tags
|
echo "$TAGS" | head -n $REMAIN > /tmp/old_tags
|
||||||
else
|
else
|
||||||
echo less than 10 tags, skipping cleanup
|
echo less than 10 tags, skipping cleanup
|
||||||
|
|||||||
@@ -295,7 +295,7 @@ public class SqliteDb extends BaseDb implements AccountDb {
|
|||||||
}
|
}
|
||||||
} else if (transaction.isDirty()) {
|
} else if (transaction.isDirty()) {
|
||||||
try {
|
try {
|
||||||
if (transaction.amount() == 0 || transaction.source().isEmpty() || transaction.destination().isEmpty()) {
|
if (transaction.amount() == 0) {
|
||||||
delete().from(TABLE_TRANSACTIONS).where(Field.ID, equal(transaction.id())).where(ACCOUNT, equal(transaction.accountId())).execute(db);
|
delete().from(TABLE_TRANSACTIONS).where(Field.ID, equal(transaction.id())).where(ACCOUNT, equal(transaction.accountId())).execute(db);
|
||||||
} else {
|
} else {
|
||||||
replaceInto(TABLE_TRANSACTIONS, Field.ID, Field.ACCOUNT, Field.TIMESTAMP, Field.SOURCE, Field.DESTINATION, Field.AMOUNT, Field.DESCRIPTION)
|
replaceInto(TABLE_TRANSACTIONS, Field.ID, Field.ACCOUNT, Field.TIMESTAMP, Field.SOURCE, Field.DESTINATION, Field.AMOUNT, Field.DESCRIPTION)
|
||||||
|
|||||||
@@ -6,9 +6,6 @@ import de.srsoftware.umbrella.core.constants.Field;
|
|||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
import static de.srsoftware.tools.Optionals.isSet;
|
|
||||||
import static de.srsoftware.tools.Optionals.nullIfEmpty;
|
|
||||||
|
|
||||||
public class IdOrString implements Mappable {
|
public class IdOrString implements Mappable {
|
||||||
private final Long id;
|
private final Long id;
|
||||||
private final String value;
|
private final String value;
|
||||||
@@ -55,10 +52,6 @@ public class IdOrString implements Mappable {
|
|||||||
return map;
|
return map;
|
||||||
}
|
}
|
||||||
|
|
||||||
public boolean isEmpty() {
|
|
||||||
return id == null && !isSet(value);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String toString() {
|
public String toString() {
|
||||||
return value;
|
return value;
|
||||||
@@ -67,4 +60,4 @@ public class IdOrString implements Mappable {
|
|||||||
public String value(){
|
public String value(){
|
||||||
return value;
|
return value;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -13,8 +13,6 @@ import de.srsoftware.umbrella.core.BaseDb;
|
|||||||
import de.srsoftware.umbrella.messagebus.events.Event;
|
import de.srsoftware.umbrella.messagebus.events.Event;
|
||||||
import java.sql.Connection;
|
import java.sql.Connection;
|
||||||
import java.sql.SQLException;
|
import java.sql.SQLException;
|
||||||
import java.time.LocalDateTime;
|
|
||||||
import java.time.ZoneOffset;
|
|
||||||
|
|
||||||
public class SqliteDb extends BaseDb implements JournalDb{
|
public class SqliteDb extends BaseDb implements JournalDb{
|
||||||
public SqliteDb(Connection connection) {
|
public SqliteDb(Connection connection) {
|
||||||
@@ -35,14 +33,13 @@ public class SqliteDb extends BaseDb implements JournalDb{
|
|||||||
var sql = """
|
var sql = """
|
||||||
CREATE TABLE IF NOT EXISTS {0} (
|
CREATE TABLE IF NOT EXISTS {0} (
|
||||||
{1} INTEGER PRIMARY KEY,
|
{1} INTEGER PRIMARY KEY,
|
||||||
{2} LONG NOT NULL,
|
{2} INTEGER,
|
||||||
{3} INTEGER,
|
{3} VARCHAR(255) NOT NULL,
|
||||||
{4} VARCHAR(255) NOT NULL,
|
{4} VARCHAR(16) NOT NULL,
|
||||||
{5} VARCHAR(16) NOT NULL,
|
{5} TEXT
|
||||||
{6} TEXT
|
|
||||||
);
|
);
|
||||||
""";
|
""";
|
||||||
sql = format(sql,TABLE_JOURNAL,ID,TIMESTAMP,USER_ID,MODULE,ACTION,DESCRIPTION);
|
sql = format(sql,TABLE_JOURNAL,ID,USER_ID,MODULE,ACTION,DESCRIPTION);
|
||||||
try {
|
try {
|
||||||
db.prepareStatement(sql).execute();
|
db.prepareStatement(sql).execute();
|
||||||
} catch (SQLException e) {
|
} catch (SQLException e) {
|
||||||
@@ -53,9 +50,8 @@ public class SqliteDb extends BaseDb implements JournalDb{
|
|||||||
@Override
|
@Override
|
||||||
public void logEvent(Event<?> event) {
|
public void logEvent(Event<?> event) {
|
||||||
try {
|
try {
|
||||||
var timestamp = LocalDateTime.now().toEpochSecond(ZoneOffset.UTC);
|
insertInto(TABLE_JOURNAL,USER_ID,MODULE,ACTION,DESCRIPTION)
|
||||||
insertInto(TABLE_JOURNAL,TIMESTAMP,USER_ID,MODULE,ACTION,DESCRIPTION)
|
.values(event.initiator().id(), event.module(), event.eventType(), event.describe())
|
||||||
.values(timestamp,event.initiator().id(), event.module(), event.eventType(), event.describe())
|
|
||||||
.execute(db).close();
|
.execute(db).close();
|
||||||
} catch (SQLException e) {
|
} catch (SQLException e) {
|
||||||
throw databaseException(ERROR_WRITE_EVENT,event.eventType(),event.initiator().name());
|
throw databaseException(ERROR_WRITE_EVENT,event.eventType(),event.initiator().name());
|
||||||
|
|||||||
Reference in New Issue
Block a user