old folder
tmp
This commit is contained in:
4
.github/workflows/docker-image.yml
vendored
4
.github/workflows/docker-image.yml
vendored
@@ -48,10 +48,10 @@ jobs:
|
|||||||
|
|
||||||
- name: Push Docker image
|
- name: Push Docker image
|
||||||
run: |
|
run: |
|
||||||
# If on v1.0 branch, push to 'testing-v1.0' tag
|
# If on v1.0 branch, push to 'testing.v1.0' tag
|
||||||
if [[ "${{ github.ref }}" == "refs/heads/v1.0" ]]; then
|
if [[ "${{ github.ref }}" == "refs/heads/v1.0" ]]; then
|
||||||
docker tag ti1:${{ env.VERSION }} ${{ secrets.DOCKER_USERNAME }}/ti1:testing-v1.0
|
docker tag ti1:${{ env.VERSION }} ${{ secrets.DOCKER_USERNAME }}/ti1:testing-v1.0
|
||||||
docker push ${{ secrets.DOCKER_USERNAME }}/ti1:testing-v1.0
|
docker push ${{ secrets.DOCKER_USERNAME }}/ti1:testing.v1.0
|
||||||
else
|
else
|
||||||
# Always push to 'dev' tag for main and dev branches
|
# Always push to 'dev' tag for main and dev branches
|
||||||
docker tag ti1:${{ env.VERSION }} ${{ secrets.DOCKER_USERNAME }}/ti1:dev
|
docker tag ti1:${{ env.VERSION }} ${{ secrets.DOCKER_USERNAME }}/ti1:dev
|
||||||
|
|||||||
89
databaseold/EstimatedCall.go
Normal file
89
databaseold/EstimatedCall.go
Normal file
@@ -0,0 +1,89 @@
|
|||||||
|
package databaseold
|
||||||
|
|
||||||
|
import (
|
||||||
|
"context"
|
||||||
|
"crypto/md5"
|
||||||
|
"database/sql"
|
||||||
|
"encoding/hex"
|
||||||
|
"fmt"
|
||||||
|
"ti1/valki"
|
||||||
|
|
||||||
|
"github.com/valkey-io/valkey-go"
|
||||||
|
)
|
||||||
|
|
||||||
|
func InsertOrUpdateEstimatedCall(ctx context.Context, db *sql.DB, values []interface{}, valkeyClient valkey.Client) (int, string, error) {
|
||||||
|
// Replace empty strings with nil for timestamp fields
|
||||||
|
for i, v := range values {
|
||||||
|
if str, ok := v.(string); ok && str == "" {
|
||||||
|
values[i] = nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Convert values to a single string and hash it using MD5
|
||||||
|
var valuesString string
|
||||||
|
for _, v := range values {
|
||||||
|
if v != nil {
|
||||||
|
valuesString += fmt.Sprintf("%v", v)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
hash := md5.Sum([]byte(valuesString))
|
||||||
|
hashString := hex.EncodeToString(hash[:])
|
||||||
|
//fmt.Println("HashString:", hashString)
|
||||||
|
|
||||||
|
estimatedVehicleJourneyID := values[0]
|
||||||
|
orderID := values[1]
|
||||||
|
key := fmt.Sprintf("%v.%v", estimatedVehicleJourneyID, orderID)
|
||||||
|
//fmt.Printf("Estimated Vehicle Journey ID: %v, Order ID: %v\n", estimatedVehicleJourneyID, orderID)
|
||||||
|
|
||||||
|
var err error
|
||||||
|
|
||||||
|
// Get the MD5 hash from Valkey
|
||||||
|
retrievedHash, err := valki.GetValkeyValue(ctx, valkeyClient, key)
|
||||||
|
if err != nil {
|
||||||
|
return 0, "", fmt.Errorf("failed to get value from Valkey: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Check if the retrieved value matches the original MD5 hash
|
||||||
|
if retrievedHash != hashString {
|
||||||
|
query := `
|
||||||
|
INSERT INTO calls (
|
||||||
|
estimatedvehiclejourney, "order", stoppointref,
|
||||||
|
aimeddeparturetime, expecteddeparturetime,
|
||||||
|
aimedarrivaltime, expectedarrivaltime,
|
||||||
|
cancellation, estimated_data
|
||||||
|
)
|
||||||
|
VALUES ($1,$2,$3,$4,$5,$6,$7,$8,$9)
|
||||||
|
ON CONFLICT (estimatedvehiclejourney, "order")
|
||||||
|
DO UPDATE SET
|
||||||
|
stoppointref = EXCLUDED.stoppointref,
|
||||||
|
aimeddeparturetime = EXCLUDED.aimeddeparturetime,
|
||||||
|
expecteddeparturetime = EXCLUDED.expecteddeparturetime,
|
||||||
|
aimedarrivaltime = EXCLUDED.aimedarrivaltime,
|
||||||
|
expectedarrivaltime = EXCLUDED.expectedarrivaltime,
|
||||||
|
cancellation = EXCLUDED.cancellation,
|
||||||
|
estimated_data = EXCLUDED.estimated_data
|
||||||
|
RETURNING CASE WHEN xmax = 0 THEN 'insert' ELSE 'update' END, id;
|
||||||
|
`
|
||||||
|
stmt, err := db.Prepare(query)
|
||||||
|
if err != nil {
|
||||||
|
return 0, "", fmt.Errorf("error preparing statement: %v", err)
|
||||||
|
}
|
||||||
|
defer stmt.Close()
|
||||||
|
|
||||||
|
err = valki.SetValkeyValue(ctx, valkeyClient, key, hashString)
|
||||||
|
if err != nil {
|
||||||
|
return 0, "", fmt.Errorf("failed to set value in Valkey: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
var action string
|
||||||
|
var id int
|
||||||
|
err = stmt.QueryRow(values...).Scan(&action, &id)
|
||||||
|
if err != nil {
|
||||||
|
return 0, "", fmt.Errorf("error executing statement: %v", err)
|
||||||
|
}
|
||||||
|
return id, action, nil
|
||||||
|
} else {
|
||||||
|
//fmt.Printf("MATCH!!! Original Hash: %s, Retrieved Hash: %s\n", hashString, retrievedHash)
|
||||||
|
return 0, "none", nil
|
||||||
|
}
|
||||||
|
}
|
||||||
41
databaseold/EstimatedVehicleJourney.go
Normal file
41
databaseold/EstimatedVehicleJourney.go
Normal file
@@ -0,0 +1,41 @@
|
|||||||
|
package databaseold
|
||||||
|
|
||||||
|
import (
|
||||||
|
"database/sql"
|
||||||
|
"fmt"
|
||||||
|
)
|
||||||
|
|
||||||
|
func InsertOrUpdateEstimatedVehicleJourney(db *sql.DB, values []interface{}) (int, string, error) {
|
||||||
|
query := `
|
||||||
|
INSERT INTO estimatedvehiclejourney (servicedelivery, recordedattime, lineref, directionref, datasource, datedvehiclejourneyref, vehiclemode, dataframeref, originref, destinationref, operatorref, vehicleref, cancellation, other, firstservicedelivery)
|
||||||
|
VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $1)
|
||||||
|
ON CONFLICT (lineref, directionref, datasource, datedvehiclejourneyref)
|
||||||
|
DO UPDATE SET
|
||||||
|
servicedelivery = EXCLUDED.servicedelivery,
|
||||||
|
recordedattime = EXCLUDED.recordedattime,
|
||||||
|
vehiclemode = COALESCE(EXCLUDED.vehiclemode, estimatedvehiclejourney.vehiclemode),
|
||||||
|
dataframeref = COALESCE(EXCLUDED.dataframeref, estimatedvehiclejourney.dataframeref),
|
||||||
|
originref = COALESCE(EXCLUDED.originref, estimatedvehiclejourney.originref),
|
||||||
|
destinationref = COALESCE(EXCLUDED.destinationref, estimatedvehiclejourney.destinationref),
|
||||||
|
operatorref = COALESCE(EXCLUDED.operatorref, estimatedvehiclejourney.operatorref),
|
||||||
|
vehicleref = COALESCE(EXCLUDED.vehicleref, estimatedvehiclejourney.vehicleref),
|
||||||
|
cancellation = COALESCE(EXCLUDED.cancellation, estimatedvehiclejourney.cancellation),
|
||||||
|
other = COALESCE(EXCLUDED.other, estimatedvehiclejourney.other)
|
||||||
|
RETURNING CASE WHEN xmax = 0 THEN 'insert' ELSE 'update' END, id;
|
||||||
|
`
|
||||||
|
|
||||||
|
stmt, err := db.Prepare(query)
|
||||||
|
if err != nil {
|
||||||
|
return 0, "", fmt.Errorf("error preparing statement: %v", err)
|
||||||
|
}
|
||||||
|
defer stmt.Close()
|
||||||
|
|
||||||
|
var action string
|
||||||
|
var id int
|
||||||
|
err = stmt.QueryRow(values...).Scan(&action, &id)
|
||||||
|
if err != nil {
|
||||||
|
return 0, "", fmt.Errorf("error executing statement: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return id, action, nil
|
||||||
|
}
|
||||||
89
databaseold/RecordedCall.go
Normal file
89
databaseold/RecordedCall.go
Normal file
@@ -0,0 +1,89 @@
|
|||||||
|
package databaseold
|
||||||
|
|
||||||
|
import (
|
||||||
|
"context"
|
||||||
|
"crypto/md5"
|
||||||
|
"database/sql"
|
||||||
|
"encoding/hex"
|
||||||
|
"fmt"
|
||||||
|
"ti1/valki"
|
||||||
|
|
||||||
|
"github.com/valkey-io/valkey-go"
|
||||||
|
)
|
||||||
|
|
||||||
|
func InsertOrUpdateRecordedCall(ctx context.Context, db *sql.DB, values []interface{}, valkeyClient valkey.Client) (int, string, error) {
|
||||||
|
// Replace empty strings with nil for timestamp fields
|
||||||
|
for i, v := range values {
|
||||||
|
if str, ok := v.(string); ok && str == "" {
|
||||||
|
values[i] = nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Convert values to a single string and hash it using MD5
|
||||||
|
var valuesString string
|
||||||
|
for _, v := range values {
|
||||||
|
if v != nil {
|
||||||
|
valuesString += fmt.Sprintf("%v", v)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
hash := md5.Sum([]byte(valuesString))
|
||||||
|
hashString := hex.EncodeToString(hash[:])
|
||||||
|
|
||||||
|
estimatedVehicleJourneyID := values[0]
|
||||||
|
orderID := values[1]
|
||||||
|
key := fmt.Sprintf("%v.%v", estimatedVehicleJourneyID, orderID)
|
||||||
|
|
||||||
|
var err error
|
||||||
|
|
||||||
|
// Get the MD5 hash from Valkey
|
||||||
|
retrievedHash, err := valki.GetValkeyValue(ctx, valkeyClient, key)
|
||||||
|
if err != nil {
|
||||||
|
return 0, "", fmt.Errorf("failed to get value from Valkey: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Check if the retrieved value matches the original MD5 hash
|
||||||
|
if retrievedHash != hashString {
|
||||||
|
query := `
|
||||||
|
INSERT INTO calls (
|
||||||
|
estimatedvehiclejourney, "order", stoppointref,
|
||||||
|
aimeddeparturetime, expecteddeparturetime,
|
||||||
|
aimedarrivaltime, expectedarrivaltime,
|
||||||
|
cancellation, actualdeparturetime, actualarrivaltime,
|
||||||
|
recorded_data
|
||||||
|
)
|
||||||
|
VALUES ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10,$11)
|
||||||
|
ON CONFLICT (estimatedvehiclejourney, "order")
|
||||||
|
DO UPDATE SET
|
||||||
|
stoppointref = EXCLUDED.stoppointref,
|
||||||
|
aimeddeparturetime = EXCLUDED.aimeddeparturetime,
|
||||||
|
expecteddeparturetime = EXCLUDED.expecteddeparturetime,
|
||||||
|
aimedarrivaltime = EXCLUDED.aimedarrivaltime,
|
||||||
|
expectedarrivaltime = EXCLUDED.expectedarrivaltime,
|
||||||
|
cancellation = EXCLUDED.cancellation,
|
||||||
|
actualdeparturetime = EXCLUDED.actualdeparturetime,
|
||||||
|
actualarrivaltime = EXCLUDED.actualarrivaltime,
|
||||||
|
recorded_data = EXCLUDED.recorded_data
|
||||||
|
RETURNING CASE WHEN xmax = 0 THEN 'insert' ELSE 'update' END, id;
|
||||||
|
`
|
||||||
|
stmt, err := db.Prepare(query)
|
||||||
|
if err != nil {
|
||||||
|
return 0, "", fmt.Errorf("error preparing statement: %v", err)
|
||||||
|
}
|
||||||
|
defer stmt.Close()
|
||||||
|
|
||||||
|
err = valki.SetValkeyValue(ctx, valkeyClient, key, hashString)
|
||||||
|
if err != nil {
|
||||||
|
return 0, "", fmt.Errorf("failed to set value in Valkey: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
var action string
|
||||||
|
var id int
|
||||||
|
err = stmt.QueryRow(values...).Scan(&action, &id)
|
||||||
|
if err != nil {
|
||||||
|
return 0, "", fmt.Errorf("error executing statement: %v", err)
|
||||||
|
}
|
||||||
|
return id, action, nil
|
||||||
|
} else {
|
||||||
|
return 0, "none", nil
|
||||||
|
}
|
||||||
|
}
|
||||||
30
databaseold/ServiceDeliveryDB.go
Normal file
30
databaseold/ServiceDeliveryDB.go
Normal file
@@ -0,0 +1,30 @@
|
|||||||
|
package databaseold
|
||||||
|
|
||||||
|
import (
|
||||||
|
"database/sql"
|
||||||
|
"fmt"
|
||||||
|
)
|
||||||
|
|
||||||
|
func InsertServiceDelivery(db *sql.DB, responseTimestamp string, recordedAtTime string) (int, error) {
|
||||||
|
fmt.Println("Inserting ServiceDelivery...")
|
||||||
|
var id int
|
||||||
|
|
||||||
|
err := db.QueryRow("INSERT INTO public.ServiceDelivery (ResponseTimestamp, RecordedAtTime) VALUES ($1, $2) RETURNING ID", responseTimestamp, recordedAtTime).Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
fmt.Println(err)
|
||||||
|
return 0, err
|
||||||
|
}
|
||||||
|
//fmt.Println("ServiceDelivery inserted successfully! (", id, ")")
|
||||||
|
return id, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func UpdateServiceDeliveryData(db *sql.DB, id int, data string) error {
|
||||||
|
fmt.Println("Updating ServiceDelivery data...")
|
||||||
|
_, err := db.Exec("UPDATE public.ServiceDelivery SET Data = $1 WHERE ID = $2", data, id)
|
||||||
|
if err != nil {
|
||||||
|
fmt.Println(err)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
fmt.Println("Finished with this ServiceDelivery!")
|
||||||
|
return nil
|
||||||
|
}
|
||||||
140
databaseold/SetupDB.go
Normal file
140
databaseold/SetupDB.go
Normal file
@@ -0,0 +1,140 @@
|
|||||||
|
package databaseold
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"ti1/config"
|
||||||
|
)
|
||||||
|
|
||||||
|
func SetupDB() error {
|
||||||
|
fmt.Println("Setting up the database...")
|
||||||
|
|
||||||
|
// Connect to PostgreSQL
|
||||||
|
db, err := config.ConnectToPostgreSQL()
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to connect to database: %w", err)
|
||||||
|
}
|
||||||
|
defer config.DisconnectFromPostgreSQL(db)
|
||||||
|
|
||||||
|
// Create sequences if they do not exist
|
||||||
|
sequences := []string{
|
||||||
|
"CREATE SEQUENCE IF NOT EXISTS public.calls_id_seq",
|
||||||
|
"CREATE SEQUENCE IF NOT EXISTS public.estimatedvehiclejourney_id_seq",
|
||||||
|
"CREATE SEQUENCE IF NOT EXISTS public.servicedelivery_id_seq",
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, seq := range sequences {
|
||||||
|
_, err := db.Exec(seq)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to create sequence: %w", err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Check if tables exist and have the correct structure
|
||||||
|
tables := map[string]string{
|
||||||
|
"calls": `CREATE TABLE IF NOT EXISTS public.calls (
|
||||||
|
id BIGINT PRIMARY KEY DEFAULT nextval('public.calls_id_seq'),
|
||||||
|
estimatedvehiclejourney BIGINT,
|
||||||
|
"order" INTEGER,
|
||||||
|
stoppointref VARCHAR,
|
||||||
|
aimeddeparturetime TIMESTAMP,
|
||||||
|
expecteddeparturetime TIMESTAMP,
|
||||||
|
aimedarrivaltime TIMESTAMP,
|
||||||
|
expectedarrivaltime TIMESTAMP,
|
||||||
|
cancellation VARCHAR,
|
||||||
|
actualdeparturetime TIMESTAMP,
|
||||||
|
actualarrivaltime TIMESTAMP,
|
||||||
|
estimated_data JSON,
|
||||||
|
recorded_data JSON
|
||||||
|
);`,
|
||||||
|
"estimatedvehiclejourney": `CREATE TABLE IF NOT EXISTS public.estimatedvehiclejourney (
|
||||||
|
id BIGINT PRIMARY KEY DEFAULT nextval('public.estimatedvehiclejourney_id_seq'),
|
||||||
|
servicedelivery INTEGER,
|
||||||
|
recordedattime TIMESTAMP,
|
||||||
|
lineref VARCHAR,
|
||||||
|
directionref VARCHAR,
|
||||||
|
datasource VARCHAR,
|
||||||
|
datedvehiclejourneyref VARCHAR,
|
||||||
|
vehiclemode VARCHAR,
|
||||||
|
dataframeref VARCHAR,
|
||||||
|
originref VARCHAR,
|
||||||
|
destinationref VARCHAR,
|
||||||
|
operatorref VARCHAR,
|
||||||
|
vehicleref VARCHAR,
|
||||||
|
cancellation VARCHAR,
|
||||||
|
other JSON,
|
||||||
|
firstservicedelivery INTEGER
|
||||||
|
);`,
|
||||||
|
"servicedelivery": `CREATE TABLE IF NOT EXISTS public.servicedelivery (
|
||||||
|
id INTEGER PRIMARY KEY DEFAULT nextval('public.servicedelivery_id_seq'),
|
||||||
|
responsetimestamp TIMESTAMPTZ,
|
||||||
|
recordedattime TIMESTAMPTZ,
|
||||||
|
data JSON
|
||||||
|
);`,
|
||||||
|
}
|
||||||
|
|
||||||
|
for table, createStmt := range tables {
|
||||||
|
var exists bool
|
||||||
|
err := db.QueryRow(fmt.Sprintf("SELECT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = '%s')", table)).Scan(&exists)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to check if table %s exists: %w", table, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
if !exists {
|
||||||
|
_, err := db.Exec(createStmt)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to create table %s: %w", table, err)
|
||||||
|
}
|
||||||
|
fmt.Printf("Table %s created successfully!\n", table)
|
||||||
|
} else {
|
||||||
|
fmt.Printf("Table %s already exists.\n", table)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Check if the unique constraint exists before adding it to calls table
|
||||||
|
var constraintExists bool
|
||||||
|
err = db.QueryRow(`
|
||||||
|
SELECT EXISTS (
|
||||||
|
SELECT 1
|
||||||
|
FROM pg_constraint
|
||||||
|
WHERE conname = 'unique_estimatedvehiclejourney_order'
|
||||||
|
);
|
||||||
|
`).Scan(&constraintExists)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to check if unique constraint exists: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
if !constraintExists {
|
||||||
|
_, err = db.Exec(`ALTER TABLE calls ADD CONSTRAINT unique_estimatedvehiclejourney_order UNIQUE (estimatedvehiclejourney, "order");`)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to add unique constraint to calls table: %w", err)
|
||||||
|
}
|
||||||
|
fmt.Println("Unique constraint added to calls table.")
|
||||||
|
} else {
|
||||||
|
fmt.Println("Unique constraint already exists on calls table.")
|
||||||
|
}
|
||||||
|
|
||||||
|
// Check if the unique constraint exists before adding it to estimatedvehiclejourney table
|
||||||
|
err = db.QueryRow(`
|
||||||
|
SELECT EXISTS (
|
||||||
|
SELECT 1
|
||||||
|
FROM pg_constraint
|
||||||
|
WHERE conname = 'unique_lineref_directionref_datasource_datedvehiclejourneyref'
|
||||||
|
);
|
||||||
|
`).Scan(&constraintExists)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to check if unique constraint exists: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
if !constraintExists {
|
||||||
|
_, err = db.Exec(`ALTER TABLE estimatedvehiclejourney ADD CONSTRAINT unique_lineref_directionref_datasource_datedvehiclejourneyref UNIQUE (lineref, directionref, datasource, datedvehiclejourneyref);`)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to add unique constraint to estimatedvehiclejourney table: %w", err)
|
||||||
|
}
|
||||||
|
fmt.Println("Unique constraint added to estimatedvehiclejourney table.")
|
||||||
|
} else {
|
||||||
|
fmt.Println("Unique constraint already exists on estimatedvehiclejourney table.")
|
||||||
|
}
|
||||||
|
|
||||||
|
fmt.Println("Database setup is good!")
|
||||||
|
return nil
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user