From cb7c6d2a1c0617efc92c49eaa0896bcffb274341 Mon Sep 17 00:00:00 2001 From: Anatoly Ostrovsky Date: Mon, 11 Dec 2023 19:08:25 +0200 Subject: [PATCH] quickfix tables --- go.mod | 17 +++++++++++++---- go.sum | 13 +++++++++++++ sql/0350_sessions_table.sql | 20 ++++++++++++++++++++ sql/0360_messages_table.sql | 20 ++++++++++++++++++++ sql/0370_messages_log_table.sql | 21 +++++++++++++++++++++ sql/0380_event_log_table.sql | 22 ++++++++++++++++++++++ 6 files changed, 109 insertions(+), 4 deletions(-) create mode 100644 sql/0350_sessions_table.sql create mode 100644 sql/0360_messages_table.sql create mode 100644 sql/0370_messages_log_table.sql create mode 100644 sql/0380_event_log_table.sql diff --git a/go.mod b/go.mod index 3e5bcd6..2c8b696 100644 --- a/go.mod +++ b/go.mod @@ -1,6 +1,8 @@ module open-outcry -go 1.20 +go 1.21 + +toolchain go1.21.4 require ( github.com/google/uuid v1.3.1 @@ -14,6 +16,13 @@ require ( require github.com/jmoiron/sqlx v1.3.5 +require ( + github.com/armon/go-proxyproto v0.1.0 // indirect + github.com/pkg/errors v0.9.1 // indirect + github.com/quickfixgo/quickfix v0.9.0 // indirect + golang.org/x/net v0.19.0 // indirect +) + require ( github.com/davecgh/go-spew v1.1.1 // indirect github.com/fsnotify/fsnotify v1.6.0 // indirect @@ -29,9 +38,9 @@ require ( github.com/spf13/jwalterweatherman v1.1.0 // indirect github.com/spf13/pflag v1.0.5 // indirect github.com/subosito/gotenv v1.4.2 // indirect - golang.org/x/sys v0.10.0 // indirect - golang.org/x/text v0.11.0 // indirect - gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f // indirect + golang.org/x/sys v0.15.0 // indirect + golang.org/x/text v0.14.0 // indirect + gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect gopkg.in/ini.v1 v1.67.0 // indirect gopkg.in/yaml.v3 v3.0.1 // indirect ) diff --git a/go.sum b/go.sum index c744592..bf185d2 100644 --- a/go.sum +++ b/go.sum @@ -38,6 +38,8 @@ cloud.google.com/go/storage v1.14.0/go.mod h1:GrKmX003DSIwi9o29oFT7YDnHYwZoctc3f dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU= github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU= github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo= +github.com/armon/go-proxyproto v0.1.0 h1:TWWcSsjco7o2itn6r25/5AqKBiWmsiuzsUDLT/MTl7k= +github.com/armon/go-proxyproto v0.1.0/go.mod h1:Xj90dce2VKbHzRAeiVQAMBtj4M5oidoXJ8lmgyW21mw= github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU= github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWRnGsAI= github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e/go.mod h1:nSuG5e5PlCu98SY8svDHJxuZscDgtXS6KTTbou5AhLI= @@ -136,6 +138,7 @@ github.com/kballard/go-shellquote v0.0.0-20180428030007-95032a82bc51 h1:Z9n2FFNU github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck= github.com/kr/fs v0.1.0/go.mod h1:FFnZGqtBN9Gxj7eW1uZ42v5BccTP0vu6NEaFoC2HwRg= github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo= +github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI= github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE= github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ= github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI= @@ -153,6 +156,7 @@ github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e h1:fD57ERR4JtEqsWb github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e/go.mod h1:zD1mROLANZcx1PVRCS0qkT7pwLkGfwJo4zjcN/Tysno= github.com/pelletier/go-toml/v2 v2.0.8 h1:0ctb6s9mE31h0/lhu+J6OPmVeDxJn+kYnJc2jZR9tGQ= github.com/pelletier/go-toml/v2 v2.0.8/go.mod h1:vuYfssBdrU2XDZ9bYydBu6t+6a6PYNcZljzZR9VXg+4= +github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4= github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= github.com/pkg/sftp v1.13.1/go.mod h1:3HaPG6Dq1ILlpPZRO0HVMrsydcdLt6HRDccSgb87qRg= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= @@ -160,6 +164,8 @@ github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZN github.com/pressly/goose/v3 v3.15.0 h1:6tY5aDqFknY6VZkorFGgZtWygodZQxfmmEF4rqyJW9k= github.com/pressly/goose/v3 v3.15.0/go.mod h1:LlIo3zGccjb/YUgG+Svdb9Er14vefRdlDI7URCDrwYo= github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA= +github.com/quickfixgo/quickfix v0.9.0 h1:WshR3GUSxR69ZrSQfppKs2zZ12dTYtU3JUgQg+PAOdA= +github.com/quickfixgo/quickfix v0.9.0/go.mod h1:t5Z881dOZ2Dz5vM6KIbMCx3YpAiFPFf/iCLCSn91Qqo= github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE= github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4= github.com/rogpeppe/go-internal v1.9.0 h1:73kH8U+JUqXU8lRuOHeVHaa/SZPifC7BkcraZVejAe8= @@ -274,6 +280,8 @@ golang.org/x/net v0.0.0-20201209123823-ac852fbbde11/go.mod h1:m0MpNAwzfU5UDzcl9v golang.org/x/net v0.0.0-20201224014010-6772e930b67b/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= +golang.org/x/net v0.19.0 h1:zTwKpTd2XuCqf8huc7Fo2iSy+4RHPd10s4KzeTnVr1c= +golang.org/x/net v0.19.0/go.mod h1:CfAk/cbD4CthTvqiEl8NpboMuiuOYsAr/7NOjZJtv1U= golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U= golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= @@ -332,6 +340,8 @@ golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBc golang.org/x/sys v0.0.0-20220908164124-27713097b956/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.10.0 h1:SqMFp9UcQJZa+pmYuAKjd9xq1f0j5rLcDIk0mj4qAsA= golang.org/x/sys v0.10.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.15.0 h1:h48lPFYpsTvQJZF4EKyI4aLHaev3CxivZmv7yZig9pc= +golang.org/x/sys v0.15.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= golang.org/x/text v0.0.0-20170915032832-14c0d48ead0c/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= @@ -343,6 +353,7 @@ golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= golang.org/x/text v0.11.0 h1:LAntKIrcmeSKERyiOh0XMV39LXS8IE9UL2yP7+f5ij4= golang.org/x/text v0.11.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE= +golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU= golang.org/x/time v0.0.0-20181108054448-85acf8d2951c/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= golang.org/x/time v0.0.0-20190308202827-9d24e82272b4/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= golang.org/x/time v0.0.0-20191024005414-555d28b269f0/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= @@ -490,6 +501,8 @@ gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8 gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f h1:BLraFXnmrev5lT+xlilqcH8XK9/i0At2xKjWk4p6zsU= gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk= +gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q= gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI= gopkg.in/ini.v1 v1.67.0 h1:Dgnx+6+nfE+IfzjUEISNeydPJh9AXNNsWbGP9KzCsOA= gopkg.in/ini.v1 v1.67.0/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k= diff --git a/sql/0350_sessions_table.sql b/sql/0350_sessions_table.sql new file mode 100644 index 0000000..1a1624c --- /dev/null +++ b/sql/0350_sessions_table.sql @@ -0,0 +1,20 @@ +-- +goose Up + +CREATE TABLE sessions ( + beginstring CHAR(8) NOT NULL, + sendercompid VARCHAR(64) NOT NULL, + sendersubid VARCHAR(64) NOT NULL, + senderlocid VARCHAR(64) NOT NULL, + targetcompid VARCHAR(64) NOT NULL, + targetsubid VARCHAR(64) NOT NULL, + targetlocid VARCHAR(64) NOT NULL, + session_qualifier VARCHAR(64) NOT NULL, + creation_time TIMESTAMP WITH TIME ZONE NOT NULL, + incoming_seqnum INTEGER NOT NULL, + outgoing_seqnum INTEGER NOT NULL, + PRIMARY KEY (beginstring, sendercompid, sendersubid, senderlocid, + targetcompid, targetsubid, targetlocid, session_qualifier) +); + +-- +goose Down +DROP TABLE sessions CASCADE; \ No newline at end of file diff --git a/sql/0360_messages_table.sql b/sql/0360_messages_table.sql new file mode 100644 index 0000000..6693df8 --- /dev/null +++ b/sql/0360_messages_table.sql @@ -0,0 +1,20 @@ +-- +goose Up + +CREATE TABLE messages ( + beginstring CHAR(8) NOT NULL, + sendercompid VARCHAR(64) NOT NULL, + sendersubid VARCHAR(64) NOT NULL, + senderlocid VARCHAR(64) NOT NULL, + targetcompid VARCHAR(64) NOT NULL, + targetsubid VARCHAR(64) NOT NULL, + targetlocid VARCHAR(64) NOT NULL, + session_qualifier VARCHAR(64) NOT NULL, + msgseqnum INTEGER NOT NULL, + message TEXT NOT NULL, + PRIMARY KEY (beginstring, sendercompid, sendersubid, senderlocid, + targetcompid, targetsubid, targetlocid, session_qualifier, + msgseqnum) +); + +-- +goose Down +DROP TABLE messages CASCADE; \ No newline at end of file diff --git a/sql/0370_messages_log_table.sql b/sql/0370_messages_log_table.sql new file mode 100644 index 0000000..c604559 --- /dev/null +++ b/sql/0370_messages_log_table.sql @@ -0,0 +1,21 @@ +-- +goose Up +CREATE SEQUENCE messages_log_sequence; + +CREATE TABLE messages_log ( + id INTEGER DEFAULT NEXTVAL('messages_log_sequence'), + time TIMESTAMP WITH TIME ZONE NOT NULL, + beginstring CHAR(8) NOT NULL, + sendercompid VARCHAR(64) NOT NULL, + sendersubid VARCHAR(64) NOT NULL, + senderlocid VARCHAR(64) NOT NULL, + targetcompid VARCHAR(64) NOT NULL, + targetsubid VARCHAR(64) NOT NULL, + targetlocid VARCHAR(64) NOT NULL, + session_qualifier VARCHAR(64), + text TEXT NOT NULL, + PRIMARY KEY (id) +); + +-- +goose Down +DROP TABLE messages_log CASCADE; +DROP SEQUENCE messages_log_sequence; \ No newline at end of file diff --git a/sql/0380_event_log_table.sql b/sql/0380_event_log_table.sql new file mode 100644 index 0000000..3507721 --- /dev/null +++ b/sql/0380_event_log_table.sql @@ -0,0 +1,22 @@ +-- +goose Up + +CREATE SEQUENCE event_log_sequence; + +CREATE TABLE event_log ( + id INTEGER DEFAULT NEXTVAL('event_log_sequence'), + time TIMESTAMP WITH TIME ZONE NOT NULL, + beginstring CHAR(8) NOT NULL, + sendercompid VARCHAR(64) NOT NULL, + sendersubid VARCHAR(64) NOT NULL, + senderlocid VARCHAR(64) NOT NULL, + targetcompid VARCHAR(64) NOT NULL, + targetsubid VARCHAR(64) NOT NULL, + targetlocid VARCHAR(64) NOT NULL, + session_qualifier VARCHAR(64), + text TEXT NOT NULL, + PRIMARY KEY (id) +); + +-- +goose Down +DROP TABLE event_log CASCADE; +DROP SEQUENCE event_log_sequence; \ No newline at end of file