Compare commits

...

4 Commits

17 changed files with 1500 additions and 208 deletions

507
client/package-lock.json generated
View File

@@ -8,6 +8,11 @@
"name": "client", "name": "client",
"version": "0.1.0", "version": "0.1.0",
"dependencies": { "dependencies": {
"@emotion/react": "^11.14.0",
"@emotion/styled": "^11.14.1",
"@mui/icons-material": "^7.3.7",
"@mui/material": "^7.3.7",
"axios": "^1.13.2",
"cra-template-pwa": "2.0.0", "cra-template-pwa": "2.0.0",
"react": "^19.2.3", "react": "^19.2.3",
"react-dom": "^19.2.3", "react-dom": "^19.2.3",
@@ -2206,6 +2211,152 @@
"postcss-selector-parser": "^6.0.10" "postcss-selector-parser": "^6.0.10"
} }
}, },
"node_modules/@emotion/babel-plugin": {
"version": "11.13.5",
"resolved": "https://registry.npmjs.org/@emotion/babel-plugin/-/babel-plugin-11.13.5.tgz",
"integrity": "sha512-pxHCpT2ex+0q+HH91/zsdHkw/lXd468DIN2zvfvLtPKLLMo6gQj7oLObq8PhkrxOZb/gGCq03S3Z7PDhS8pduQ==",
"dependencies": {
"@babel/helper-module-imports": "^7.16.7",
"@babel/runtime": "^7.18.3",
"@emotion/hash": "^0.9.2",
"@emotion/memoize": "^0.9.0",
"@emotion/serialize": "^1.3.3",
"babel-plugin-macros": "^3.1.0",
"convert-source-map": "^1.5.0",
"escape-string-regexp": "^4.0.0",
"find-root": "^1.1.0",
"source-map": "^0.5.7",
"stylis": "4.2.0"
}
},
"node_modules/@emotion/babel-plugin/node_modules/convert-source-map": {
"version": "1.9.0",
"resolved": "https://registry.npmjs.org/convert-source-map/-/convert-source-map-1.9.0.tgz",
"integrity": "sha512-ASFBup0Mz1uyiIjANan1jzLQami9z1PoYSZCiiYW2FczPbenXc45FZdBZLzOT+r6+iciuEModtmCti+hjaAk0A=="
},
"node_modules/@emotion/babel-plugin/node_modules/source-map": {
"version": "0.5.7",
"resolved": "https://registry.npmjs.org/source-map/-/source-map-0.5.7.tgz",
"integrity": "sha512-LbrmJOMUSdEVxIKvdcJzQC+nQhe8FUZQTXQy6+I75skNgn3OoQ0DZA8YnFa7gp8tqtL3KPf1kmo0R5DoApeSGQ==",
"engines": {
"node": ">=0.10.0"
}
},
"node_modules/@emotion/cache": {
"version": "11.14.0",
"resolved": "https://registry.npmjs.org/@emotion/cache/-/cache-11.14.0.tgz",
"integrity": "sha512-L/B1lc/TViYk4DcpGxtAVbx0ZyiKM5ktoIyafGkH6zg/tj+mA+NE//aPYKG0k8kCHSHVJrpLpcAlOBEXQ3SavA==",
"dependencies": {
"@emotion/memoize": "^0.9.0",
"@emotion/sheet": "^1.4.0",
"@emotion/utils": "^1.4.2",
"@emotion/weak-memoize": "^0.4.0",
"stylis": "4.2.0"
}
},
"node_modules/@emotion/hash": {
"version": "0.9.2",
"resolved": "https://registry.npmjs.org/@emotion/hash/-/hash-0.9.2.tgz",
"integrity": "sha512-MyqliTZGuOm3+5ZRSaaBGP3USLw6+EGykkwZns2EPC5g8jJ4z9OrdZY9apkl3+UP9+sdz76YYkwCKP5gh8iY3g=="
},
"node_modules/@emotion/is-prop-valid": {
"version": "1.4.0",
"resolved": "https://registry.npmjs.org/@emotion/is-prop-valid/-/is-prop-valid-1.4.0.tgz",
"integrity": "sha512-QgD4fyscGcbbKwJmqNvUMSE02OsHUa+lAWKdEUIJKgqe5IwRSKd7+KhibEWdaKwgjLj0DRSHA9biAIqGBk05lw==",
"dependencies": {
"@emotion/memoize": "^0.9.0"
}
},
"node_modules/@emotion/memoize": {
"version": "0.9.0",
"resolved": "https://registry.npmjs.org/@emotion/memoize/-/memoize-0.9.0.tgz",
"integrity": "sha512-30FAj7/EoJ5mwVPOWhAyCX+FPfMDrVecJAM+Iw9NRoSl4BBAQeqj4cApHHUXOVvIPgLVDsCFoz/hGD+5QQD1GQ=="
},
"node_modules/@emotion/react": {
"version": "11.14.0",
"resolved": "https://registry.npmjs.org/@emotion/react/-/react-11.14.0.tgz",
"integrity": "sha512-O000MLDBDdk/EohJPFUqvnp4qnHeYkVP5B0xEG0D/L7cOKP9kefu2DXn8dj74cQfsEzUqh+sr1RzFqiL1o+PpA==",
"dependencies": {
"@babel/runtime": "^7.18.3",
"@emotion/babel-plugin": "^11.13.5",
"@emotion/cache": "^11.14.0",
"@emotion/serialize": "^1.3.3",
"@emotion/use-insertion-effect-with-fallbacks": "^1.2.0",
"@emotion/utils": "^1.4.2",
"@emotion/weak-memoize": "^0.4.0",
"hoist-non-react-statics": "^3.3.1"
},
"peerDependencies": {
"react": ">=16.8.0"
},
"peerDependenciesMeta": {
"@types/react": {
"optional": true
}
}
},
"node_modules/@emotion/serialize": {
"version": "1.3.3",
"resolved": "https://registry.npmjs.org/@emotion/serialize/-/serialize-1.3.3.tgz",
"integrity": "sha512-EISGqt7sSNWHGI76hC7x1CksiXPahbxEOrC5RjmFRJTqLyEK9/9hZvBbiYn70dw4wuwMKiEMCUlR6ZXTSWQqxA==",
"dependencies": {
"@emotion/hash": "^0.9.2",
"@emotion/memoize": "^0.9.0",
"@emotion/unitless": "^0.10.0",
"@emotion/utils": "^1.4.2",
"csstype": "^3.0.2"
}
},
"node_modules/@emotion/sheet": {
"version": "1.4.0",
"resolved": "https://registry.npmjs.org/@emotion/sheet/-/sheet-1.4.0.tgz",
"integrity": "sha512-fTBW9/8r2w3dXWYM4HCB1Rdp8NLibOw2+XELH5m5+AkWiL/KqYX6dc0kKYlaYyKjrQ6ds33MCdMPEwgs2z1rqg=="
},
"node_modules/@emotion/styled": {
"version": "11.14.1",
"resolved": "https://registry.npmjs.org/@emotion/styled/-/styled-11.14.1.tgz",
"integrity": "sha512-qEEJt42DuToa3gurlH4Qqc1kVpNq8wO8cJtDzU46TjlzWjDlsVyevtYCRijVq3SrHsROS+gVQ8Fnea108GnKzw==",
"dependencies": {
"@babel/runtime": "^7.18.3",
"@emotion/babel-plugin": "^11.13.5",
"@emotion/is-prop-valid": "^1.3.0",
"@emotion/serialize": "^1.3.3",
"@emotion/use-insertion-effect-with-fallbacks": "^1.2.0",
"@emotion/utils": "^1.4.2"
},
"peerDependencies": {
"@emotion/react": "^11.0.0-rc.0",
"react": ">=16.8.0"
},
"peerDependenciesMeta": {
"@types/react": {
"optional": true
}
}
},
"node_modules/@emotion/unitless": {
"version": "0.10.0",
"resolved": "https://registry.npmjs.org/@emotion/unitless/-/unitless-0.10.0.tgz",
"integrity": "sha512-dFoMUuQA20zvtVTuxZww6OHoJYgrzfKM1t52mVySDJnMSEa08ruEvdYQbhvyu6soU+NeLVd3yKfTfT0NeV6qGg=="
},
"node_modules/@emotion/use-insertion-effect-with-fallbacks": {
"version": "1.2.0",
"resolved": "https://registry.npmjs.org/@emotion/use-insertion-effect-with-fallbacks/-/use-insertion-effect-with-fallbacks-1.2.0.tgz",
"integrity": "sha512-yJMtVdH59sxi/aVJBpk9FQq+OR8ll5GT8oWd57UpeaKEVGab41JWaCFA7FRLoMLloOZF/c/wsPoe+bfGmRKgDg==",
"peerDependencies": {
"react": ">=16.8.0"
}
},
"node_modules/@emotion/utils": {
"version": "1.4.2",
"resolved": "https://registry.npmjs.org/@emotion/utils/-/utils-1.4.2.tgz",
"integrity": "sha512-3vLclRofFziIa3J2wDh9jjbkUz9qk5Vi3IZ/FSTKViB0k+ef0fPV7dYrUIugbgupYDx7v9ud/SjrtEP8Y4xLoA=="
},
"node_modules/@emotion/weak-memoize": {
"version": "0.4.0",
"resolved": "https://registry.npmjs.org/@emotion/weak-memoize/-/weak-memoize-0.4.0.tgz",
"integrity": "sha512-snKqtPW01tN0ui7yu9rGv69aJXr/a/Ywvl11sUjNtEcRc+ng/mQriFL0wLXMef74iHa/EkftbDzU9F8iFbH+zg=="
},
"node_modules/@eslint-community/eslint-utils": { "node_modules/@eslint-community/eslint-utils": {
"version": "4.9.1", "version": "4.9.1",
"resolved": "https://registry.npmjs.org/@eslint-community/eslint-utils/-/eslint-utils-4.9.1.tgz", "resolved": "https://registry.npmjs.org/@eslint-community/eslint-utils/-/eslint-utils-4.9.1.tgz",
@@ -2663,6 +2814,241 @@
"resolved": "https://registry.npmjs.org/@leichtgewicht/ip-codec/-/ip-codec-2.0.5.tgz", "resolved": "https://registry.npmjs.org/@leichtgewicht/ip-codec/-/ip-codec-2.0.5.tgz",
"integrity": "sha512-Vo+PSpZG2/fmgmiNzYK9qWRh8h/CHrwD0mo1h1DzL4yzHNSfWYujGTYsWGreD000gcgmZ7K4Ys6Tx9TxtsKdDw==" "integrity": "sha512-Vo+PSpZG2/fmgmiNzYK9qWRh8h/CHrwD0mo1h1DzL4yzHNSfWYujGTYsWGreD000gcgmZ7K4Ys6Tx9TxtsKdDw=="
}, },
"node_modules/@mui/core-downloads-tracker": {
"version": "7.3.7",
"resolved": "https://registry.npmjs.org/@mui/core-downloads-tracker/-/core-downloads-tracker-7.3.7.tgz",
"integrity": "sha512-8jWwS6FweMkpyRkrJooamUGe1CQfO1yJ+lM43IyUJbrhHW/ObES+6ry4vfGi8EKaldHL3t3BG1bcLcERuJPcjg==",
"funding": {
"type": "opencollective",
"url": "https://opencollective.com/mui-org"
}
},
"node_modules/@mui/icons-material": {
"version": "7.3.7",
"resolved": "https://registry.npmjs.org/@mui/icons-material/-/icons-material-7.3.7.tgz",
"integrity": "sha512-3Q+ulAqG+A1+R4ebgoIs7AccaJhIGy+Xi/9OnvX376jQ6wcy+rz4geDGrxQxCGzdjOQr4Z3NgyFSZCz4T999lA==",
"dependencies": {
"@babel/runtime": "^7.28.4"
},
"engines": {
"node": ">=14.0.0"
},
"funding": {
"type": "opencollective",
"url": "https://opencollective.com/mui-org"
},
"peerDependencies": {
"@mui/material": "^7.3.7",
"@types/react": "^17.0.0 || ^18.0.0 || ^19.0.0",
"react": "^17.0.0 || ^18.0.0 || ^19.0.0"
},
"peerDependenciesMeta": {
"@types/react": {
"optional": true
}
}
},
"node_modules/@mui/material": {
"version": "7.3.7",
"resolved": "https://registry.npmjs.org/@mui/material/-/material-7.3.7.tgz",
"integrity": "sha512-6bdIxqzeOtBAj2wAsfhWCYyMKPLkRO9u/2o5yexcL0C3APqyy91iGSWgT3H7hg+zR2XgE61+WAu12wXPON8b6A==",
"dependencies": {
"@babel/runtime": "^7.28.4",
"@mui/core-downloads-tracker": "^7.3.7",
"@mui/system": "^7.3.7",
"@mui/types": "^7.4.10",
"@mui/utils": "^7.3.7",
"@popperjs/core": "^2.11.8",
"@types/react-transition-group": "^4.4.12",
"clsx": "^2.1.1",
"csstype": "^3.2.3",
"prop-types": "^15.8.1",
"react-is": "^19.2.3",
"react-transition-group": "^4.4.5"
},
"engines": {
"node": ">=14.0.0"
},
"funding": {
"type": "opencollective",
"url": "https://opencollective.com/mui-org"
},
"peerDependencies": {
"@emotion/react": "^11.5.0",
"@emotion/styled": "^11.3.0",
"@mui/material-pigment-css": "^7.3.7",
"@types/react": "^17.0.0 || ^18.0.0 || ^19.0.0",
"react": "^17.0.0 || ^18.0.0 || ^19.0.0",
"react-dom": "^17.0.0 || ^18.0.0 || ^19.0.0"
},
"peerDependenciesMeta": {
"@emotion/react": {
"optional": true
},
"@emotion/styled": {
"optional": true
},
"@mui/material-pigment-css": {
"optional": true
},
"@types/react": {
"optional": true
}
}
},
"node_modules/@mui/material/node_modules/react-is": {
"version": "19.2.3",
"resolved": "https://registry.npmjs.org/react-is/-/react-is-19.2.3.tgz",
"integrity": "sha512-qJNJfu81ByyabuG7hPFEbXqNcWSU3+eVus+KJs+0ncpGfMyYdvSmxiJxbWR65lYi1I+/0HBcliO029gc4F+PnA=="
},
"node_modules/@mui/private-theming": {
"version": "7.3.7",
"resolved": "https://registry.npmjs.org/@mui/private-theming/-/private-theming-7.3.7.tgz",
"integrity": "sha512-w7r1+CYhG0syCAQUWAuV5zSaU2/67WA9JXUderdb7DzCIJdp/5RmJv6L85wRjgKCMsxFF0Kfn0kPgPbPgw/jdw==",
"dependencies": {
"@babel/runtime": "^7.28.4",
"@mui/utils": "^7.3.7",
"prop-types": "^15.8.1"
},
"engines": {
"node": ">=14.0.0"
},
"funding": {
"type": "opencollective",
"url": "https://opencollective.com/mui-org"
},
"peerDependencies": {
"@types/react": "^17.0.0 || ^18.0.0 || ^19.0.0",
"react": "^17.0.0 || ^18.0.0 || ^19.0.0"
},
"peerDependenciesMeta": {
"@types/react": {
"optional": true
}
}
},
"node_modules/@mui/styled-engine": {
"version": "7.3.7",
"resolved": "https://registry.npmjs.org/@mui/styled-engine/-/styled-engine-7.3.7.tgz",
"integrity": "sha512-y/QkNXv6cF6dZ5APztd/dFWfQ6LHKPx3skyYO38YhQD4+Cxd6sFAL3Z38WMSSC8LQz145Mpp3CcLrSCLKPwYAg==",
"dependencies": {
"@babel/runtime": "^7.28.4",
"@emotion/cache": "^11.14.0",
"@emotion/serialize": "^1.3.3",
"@emotion/sheet": "^1.4.0",
"csstype": "^3.2.3",
"prop-types": "^15.8.1"
},
"engines": {
"node": ">=14.0.0"
},
"funding": {
"type": "opencollective",
"url": "https://opencollective.com/mui-org"
},
"peerDependencies": {
"@emotion/react": "^11.4.1",
"@emotion/styled": "^11.3.0",
"react": "^17.0.0 || ^18.0.0 || ^19.0.0"
},
"peerDependenciesMeta": {
"@emotion/react": {
"optional": true
},
"@emotion/styled": {
"optional": true
}
}
},
"node_modules/@mui/system": {
"version": "7.3.7",
"resolved": "https://registry.npmjs.org/@mui/system/-/system-7.3.7.tgz",
"integrity": "sha512-DovL3k+FBRKnhmatzUMyO5bKkhMLlQ9L7Qw5qHrre3m8zCZmE+31NDVBFfqrbrA7sq681qaEIHdkWD5nmiAjyQ==",
"dependencies": {
"@babel/runtime": "^7.28.4",
"@mui/private-theming": "^7.3.7",
"@mui/styled-engine": "^7.3.7",
"@mui/types": "^7.4.10",
"@mui/utils": "^7.3.7",
"clsx": "^2.1.1",
"csstype": "^3.2.3",
"prop-types": "^15.8.1"
},
"engines": {
"node": ">=14.0.0"
},
"funding": {
"type": "opencollective",
"url": "https://opencollective.com/mui-org"
},
"peerDependencies": {
"@emotion/react": "^11.5.0",
"@emotion/styled": "^11.3.0",
"@types/react": "^17.0.0 || ^18.0.0 || ^19.0.0",
"react": "^17.0.0 || ^18.0.0 || ^19.0.0"
},
"peerDependenciesMeta": {
"@emotion/react": {
"optional": true
},
"@emotion/styled": {
"optional": true
},
"@types/react": {
"optional": true
}
}
},
"node_modules/@mui/types": {
"version": "7.4.10",
"resolved": "https://registry.npmjs.org/@mui/types/-/types-7.4.10.tgz",
"integrity": "sha512-0+4mSjknSu218GW3isRqoxKRTOrTLd/vHi/7UC4+wZcUrOAqD9kRk7UQRL1mcrzqRoe7s3UT6rsRpbLkW5mHpQ==",
"dependencies": {
"@babel/runtime": "^7.28.4"
},
"peerDependencies": {
"@types/react": "^17.0.0 || ^18.0.0 || ^19.0.0"
},
"peerDependenciesMeta": {
"@types/react": {
"optional": true
}
}
},
"node_modules/@mui/utils": {
"version": "7.3.7",
"resolved": "https://registry.npmjs.org/@mui/utils/-/utils-7.3.7.tgz",
"integrity": "sha512-+YjnjMRnyeTkWnspzoxRdiSOgkrcpTikhNPoxOZW0APXx+urHtUoXJ9lbtCZRCA5a4dg5gSbd19alL1DvRs5fg==",
"dependencies": {
"@babel/runtime": "^7.28.4",
"@mui/types": "^7.4.10",
"@types/prop-types": "^15.7.15",
"clsx": "^2.1.1",
"prop-types": "^15.8.1",
"react-is": "^19.2.3"
},
"engines": {
"node": ">=14.0.0"
},
"funding": {
"type": "opencollective",
"url": "https://opencollective.com/mui-org"
},
"peerDependencies": {
"@types/react": "^17.0.0 || ^18.0.0 || ^19.0.0",
"react": "^17.0.0 || ^18.0.0 || ^19.0.0"
},
"peerDependenciesMeta": {
"@types/react": {
"optional": true
}
}
},
"node_modules/@mui/utils/node_modules/react-is": {
"version": "19.2.3",
"resolved": "https://registry.npmjs.org/react-is/-/react-is-19.2.3.tgz",
"integrity": "sha512-qJNJfu81ByyabuG7hPFEbXqNcWSU3+eVus+KJs+0ncpGfMyYdvSmxiJxbWR65lYi1I+/0HBcliO029gc4F+PnA=="
},
"node_modules/@nicolo-ribaudo/eslint-scope-5-internals": { "node_modules/@nicolo-ribaudo/eslint-scope-5-internals": {
"version": "5.1.1-v1", "version": "5.1.1-v1",
"resolved": "https://registry.npmjs.org/@nicolo-ribaudo/eslint-scope-5-internals/-/eslint-scope-5-internals-5.1.1-v1.tgz", "resolved": "https://registry.npmjs.org/@nicolo-ribaudo/eslint-scope-5-internals/-/eslint-scope-5-internals-5.1.1-v1.tgz",
@@ -2770,6 +3156,15 @@
} }
} }
}, },
"node_modules/@popperjs/core": {
"version": "2.11.8",
"resolved": "https://registry.npmjs.org/@popperjs/core/-/core-2.11.8.tgz",
"integrity": "sha512-P1st0aksCrn9sGZhp8GMYwBnQsbvAWsZAX44oXNNvLHGqAOcoVxmjZiohstwQ7SqKnbR47akdNi+uleWD8+g6A==",
"funding": {
"type": "opencollective",
"url": "https://opencollective.com/popperjs"
}
},
"node_modules/@rollup/plugin-babel": { "node_modules/@rollup/plugin-babel": {
"version": "5.3.1", "version": "5.3.1",
"resolved": "https://registry.npmjs.org/@rollup/plugin-babel/-/plugin-babel-5.3.1.tgz", "resolved": "https://registry.npmjs.org/@rollup/plugin-babel/-/plugin-babel-5.3.1.tgz",
@@ -3324,6 +3719,11 @@
"resolved": "https://registry.npmjs.org/@types/prettier/-/prettier-2.7.3.tgz", "resolved": "https://registry.npmjs.org/@types/prettier/-/prettier-2.7.3.tgz",
"integrity": "sha512-+68kP9yzs4LMp7VNh8gdzMSPZFL44MLGqiHWvttYJe+6qnuVr4Ek9wSBQoveqY/r+LwjCcU29kNVkidwim+kYA==" "integrity": "sha512-+68kP9yzs4LMp7VNh8gdzMSPZFL44MLGqiHWvttYJe+6qnuVr4Ek9wSBQoveqY/r+LwjCcU29kNVkidwim+kYA=="
}, },
"node_modules/@types/prop-types": {
"version": "15.7.15",
"resolved": "https://registry.npmjs.org/@types/prop-types/-/prop-types-15.7.15.tgz",
"integrity": "sha512-F6bEyamV9jKGAFBEmlQnesRPGOQqS2+Uwi0Em15xenOxHaf2hv6L8YCVn3rPdPJOiJfPiCnLIRyvwVaqMY3MIw=="
},
"node_modules/@types/q": { "node_modules/@types/q": {
"version": "1.5.8", "version": "1.5.8",
"resolved": "https://registry.npmjs.org/@types/q/-/q-1.5.8.tgz", "resolved": "https://registry.npmjs.org/@types/q/-/q-1.5.8.tgz",
@@ -3339,6 +3739,23 @@
"resolved": "https://registry.npmjs.org/@types/range-parser/-/range-parser-1.2.7.tgz", "resolved": "https://registry.npmjs.org/@types/range-parser/-/range-parser-1.2.7.tgz",
"integrity": "sha512-hKormJbkJqzQGhziax5PItDUTMAM9uE2XXQmM37dyd4hVM+5aVl7oVxMVUiVQn2oCQFN/LKCZdvSM0pFRqbSmQ==" "integrity": "sha512-hKormJbkJqzQGhziax5PItDUTMAM9uE2XXQmM37dyd4hVM+5aVl7oVxMVUiVQn2oCQFN/LKCZdvSM0pFRqbSmQ=="
}, },
"node_modules/@types/react": {
"version": "19.2.9",
"resolved": "https://registry.npmjs.org/@types/react/-/react-19.2.9.tgz",
"integrity": "sha512-Lpo8kgb/igvMIPeNV2rsYKTgaORYdO1XGVZ4Qz3akwOj0ySGYMPlQWa8BaLn0G63D1aSaAQ5ldR06wCpChQCjA==",
"peer": true,
"dependencies": {
"csstype": "^3.2.2"
}
},
"node_modules/@types/react-transition-group": {
"version": "4.4.12",
"resolved": "https://registry.npmjs.org/@types/react-transition-group/-/react-transition-group-4.4.12.tgz",
"integrity": "sha512-8TV6R3h2j7a91c+1DXdJi3Syo69zzIZbz7Lg5tORM5LEJG7X/E6a1V3drRyBRZq7/utz7A+c4OgYLiLcYGHG6w==",
"peerDependencies": {
"@types/react": "*"
}
},
"node_modules/@types/resolve": { "node_modules/@types/resolve": {
"version": "1.17.1", "version": "1.17.1",
"resolved": "https://registry.npmjs.org/@types/resolve/-/resolve-1.17.1.tgz", "resolved": "https://registry.npmjs.org/@types/resolve/-/resolve-1.17.1.tgz",
@@ -4347,6 +4764,31 @@
"node": ">=4" "node": ">=4"
} }
}, },
"node_modules/axios": {
"version": "1.13.2",
"resolved": "https://registry.npmjs.org/axios/-/axios-1.13.2.tgz",
"integrity": "sha512-VPk9ebNqPcy5lRGuSlKx752IlDatOjT9paPlm8A7yOuW2Fbvp4X3JznJtT4f0GzGLLiWE9W8onz51SqLYwzGaA==",
"dependencies": {
"follow-redirects": "^1.15.6",
"form-data": "^4.0.4",
"proxy-from-env": "^1.1.0"
}
},
"node_modules/axios/node_modules/form-data": {
"version": "4.0.5",
"resolved": "https://registry.npmjs.org/form-data/-/form-data-4.0.5.tgz",
"integrity": "sha512-8RipRLol37bNs2bhoV67fiTEvdTrbMUYcFTiy3+wuuOnUog2QBHCZWXDRijWQfAkhBj2Uf5UnVaiWwA5vdd82w==",
"dependencies": {
"asynckit": "^0.4.0",
"combined-stream": "^1.0.8",
"es-set-tostringtag": "^2.1.0",
"hasown": "^2.0.2",
"mime-types": "^2.1.12"
},
"engines": {
"node": ">= 6"
}
},
"node_modules/axobject-query": { "node_modules/axobject-query": {
"version": "4.1.0", "version": "4.1.0",
"resolved": "https://registry.npmjs.org/axobject-query/-/axobject-query-4.1.0.tgz", "resolved": "https://registry.npmjs.org/axobject-query/-/axobject-query-4.1.0.tgz",
@@ -5036,6 +5478,14 @@
"wrap-ansi": "^7.0.0" "wrap-ansi": "^7.0.0"
} }
}, },
"node_modules/clsx": {
"version": "2.1.1",
"resolved": "https://registry.npmjs.org/clsx/-/clsx-2.1.1.tgz",
"integrity": "sha512-eYm0QWBtUrBWZWG0d386OGAw16Z995PiOVo2B7bjWSbHedGl5e0ZWaq65kOGgUSNesEIDkB9ISbTg/JK9dhCZA==",
"engines": {
"node": ">=6"
}
},
"node_modules/co": { "node_modules/co": {
"version": "4.6.0", "version": "4.6.0",
"resolved": "https://registry.npmjs.org/co/-/co-4.6.0.tgz", "resolved": "https://registry.npmjs.org/co/-/co-4.6.0.tgz",
@@ -5707,6 +6157,11 @@
"resolved": "https://registry.npmjs.org/cssom/-/cssom-0.3.8.tgz", "resolved": "https://registry.npmjs.org/cssom/-/cssom-0.3.8.tgz",
"integrity": "sha512-b0tGHbfegbhPJpxpiBPU2sCkigAqtM9O121le6bbOlgyV+NyGyCmVfJ6QW9eRjz8CpNfWEOYBIMIGRYkLwsIYg==" "integrity": "sha512-b0tGHbfegbhPJpxpiBPU2sCkigAqtM9O121le6bbOlgyV+NyGyCmVfJ6QW9eRjz8CpNfWEOYBIMIGRYkLwsIYg=="
}, },
"node_modules/csstype": {
"version": "3.2.3",
"resolved": "https://registry.npmjs.org/csstype/-/csstype-3.2.3.tgz",
"integrity": "sha512-z1HGKcYy2xA8AGQfwrn0PAy+PB7X/GSj3UVJW9qKyn43xWa+gl5nXmU4qqLMRzWVLFC8KusUX8T/0kCiOYpAIQ=="
},
"node_modules/damerau-levenshtein": { "node_modules/damerau-levenshtein": {
"version": "1.0.8", "version": "1.0.8",
"resolved": "https://registry.npmjs.org/damerau-levenshtein/-/damerau-levenshtein-1.0.8.tgz", "resolved": "https://registry.npmjs.org/damerau-levenshtein/-/damerau-levenshtein-1.0.8.tgz",
@@ -5989,6 +6444,15 @@
"utila": "~0.4" "utila": "~0.4"
} }
}, },
"node_modules/dom-helpers": {
"version": "5.2.1",
"resolved": "https://registry.npmjs.org/dom-helpers/-/dom-helpers-5.2.1.tgz",
"integrity": "sha512-nRCa7CK3VTrM2NmGkIy4cbK7IZlgBE/PYMn55rrXefr5xXDP0LdtfPnblFDoVdcAfslJ7or6iqAUnx0CCGIWQA==",
"dependencies": {
"@babel/runtime": "^7.8.7",
"csstype": "^3.0.2"
}
},
"node_modules/dom-serializer": { "node_modules/dom-serializer": {
"version": "1.4.1", "version": "1.4.1",
"resolved": "https://registry.npmjs.org/dom-serializer/-/dom-serializer-1.4.1.tgz", "resolved": "https://registry.npmjs.org/dom-serializer/-/dom-serializer-1.4.1.tgz",
@@ -7324,6 +7788,11 @@
"url": "https://github.com/avajs/find-cache-dir?sponsor=1" "url": "https://github.com/avajs/find-cache-dir?sponsor=1"
} }
}, },
"node_modules/find-root": {
"version": "1.1.0",
"resolved": "https://registry.npmjs.org/find-root/-/find-root-1.1.0.tgz",
"integrity": "sha512-NKfW6bec6GfKc0SGx1e07QZY9PE99u0Bft/0rzSD5k3sO/vwkVUpDUKVm5Gpp5Ue3YfShPFTX2070tDs5kB9Ng=="
},
"node_modules/find-up": { "node_modules/find-up": {
"version": "4.1.0", "version": "4.1.0",
"resolved": "https://registry.npmjs.org/find-up/-/find-up-4.1.0.tgz", "resolved": "https://registry.npmjs.org/find-up/-/find-up-4.1.0.tgz",
@@ -7944,6 +8413,19 @@
"he": "bin/he" "he": "bin/he"
} }
}, },
"node_modules/hoist-non-react-statics": {
"version": "3.3.2",
"resolved": "https://registry.npmjs.org/hoist-non-react-statics/-/hoist-non-react-statics-3.3.2.tgz",
"integrity": "sha512-/gGivxi8JPKWNm/W0jSmzcMPpfpPLc3dY/6GxhX2hQ9iGj3aDfklV4ET7NjKpSinLpJ5vafa9iiGIEZg10SfBw==",
"dependencies": {
"react-is": "^16.7.0"
}
},
"node_modules/hoist-non-react-statics/node_modules/react-is": {
"version": "16.13.1",
"resolved": "https://registry.npmjs.org/react-is/-/react-is-16.13.1.tgz",
"integrity": "sha512-24e6ynE2H+OKt4kqsOvNd8kBpV65zoxbA4BVsEOB3ARVWQki/DHzaUoC5KuON/BiccDaCCTZBuOcfZs70kR8bQ=="
},
"node_modules/hoopy": { "node_modules/hoopy": {
"version": "0.1.4", "version": "0.1.4",
"resolved": "https://registry.npmjs.org/hoopy/-/hoopy-0.1.4.tgz", "resolved": "https://registry.npmjs.org/hoopy/-/hoopy-0.1.4.tgz",
@@ -12257,6 +12739,11 @@
"node": ">= 0.10" "node": ">= 0.10"
} }
}, },
"node_modules/proxy-from-env": {
"version": "1.1.0",
"resolved": "https://registry.npmjs.org/proxy-from-env/-/proxy-from-env-1.1.0.tgz",
"integrity": "sha512-D+zkORCbA9f1tdWRK0RaCR3GPv50cMxcrz4X8k5LTSUD1Dkw47mKJEZQNunItRTkWwgtaUSo1RVFRIG9ZXiFYg=="
},
"node_modules/psl": { "node_modules/psl": {
"version": "1.15.0", "version": "1.15.0",
"resolved": "https://registry.npmjs.org/psl/-/psl-1.15.0.tgz", "resolved": "https://registry.npmjs.org/psl/-/psl-1.15.0.tgz",
@@ -12630,6 +13117,21 @@
} }
} }
}, },
"node_modules/react-transition-group": {
"version": "4.4.5",
"resolved": "https://registry.npmjs.org/react-transition-group/-/react-transition-group-4.4.5.tgz",
"integrity": "sha512-pZcd1MCJoiKiBR2NRxeCRg13uCXbydPnmB4EOeRrY7480qNWO8IIgQG6zlDkm6uRMsURXPuKq0GWtiM59a5Q6g==",
"dependencies": {
"@babel/runtime": "^7.5.5",
"dom-helpers": "^5.0.1",
"loose-envify": "^1.4.0",
"prop-types": "^15.6.2"
},
"peerDependencies": {
"react": ">=16.6.0",
"react-dom": ">=16.6.0"
}
},
"node_modules/read-cache": { "node_modules/read-cache": {
"version": "1.0.0", "version": "1.0.0",
"resolved": "https://registry.npmjs.org/read-cache/-/read-cache-1.0.0.tgz", "resolved": "https://registry.npmjs.org/read-cache/-/read-cache-1.0.0.tgz",
@@ -14016,6 +14518,11 @@
"postcss": "^8.2.15" "postcss": "^8.2.15"
} }
}, },
"node_modules/stylis": {
"version": "4.2.0",
"resolved": "https://registry.npmjs.org/stylis/-/stylis-4.2.0.tgz",
"integrity": "sha512-Orov6g6BB1sDfYgzWfTHDOxamtX1bE/zo104Dh9e6fqJ3PooipYyfJ0pUmrZO2wAvO8YbEyeFrkV91XTsGMSrw=="
},
"node_modules/sucrase": { "node_modules/sucrase": {
"version": "3.35.1", "version": "3.35.1",
"resolved": "https://registry.npmjs.org/sucrase/-/sucrase-3.35.1.tgz", "resolved": "https://registry.npmjs.org/sucrase/-/sucrase-3.35.1.tgz",

View File

@@ -3,6 +3,11 @@
"version": "0.1.0", "version": "0.1.0",
"private": true, "private": true,
"dependencies": { "dependencies": {
"@emotion/react": "^11.14.0",
"@emotion/styled": "^11.14.1",
"@mui/icons-material": "^7.3.7",
"@mui/material": "^7.3.7",
"axios": "^1.13.2",
"cra-template-pwa": "2.0.0", "cra-template-pwa": "2.0.0",
"react": "^19.2.3", "react": "^19.2.3",
"react-dom": "^19.2.3", "react-dom": "^19.2.3",

View File

@@ -36,3 +36,38 @@
transform: rotate(360deg); transform: rotate(360deg);
} }
} }
.dropdown {
display: inline-block;
}
.dropbtn {
background-color: #f5f5f5;
border: none;
cursor: pointer;
}
.dropdown-content {
display: none; /* Hidden by default */
position: absolute;
background-color: #f9f9f9;
min-width: 160px;
box-shadow: 0px 8px 16px 0px rgba(0,0,0,0.2);
}
.dropdown-content a {
color: black;
padding: 12px 16px;
text-decoration: none;
display: block;
}
/* Show the dropdown menu on hover */
.dropdown:hover .dropdown-content {
display: block;
}
/* Add zebra striping to tables */
table tr:nth-child(odd) {
background-color: #f5f5f5;
}

View File

@@ -1,18 +1,45 @@
import React from "react"; import React from "react";
import { BrowserRouter, Routes, Route, Link } from "react-router"; import { BrowserRouter, Routes, Route, Link } from "react-router";
import Home from "./pages/Home"; import Home from "./pages/Home";
import AdminLogin from "./pages/AdminLogin";
import AdminMembers from "./pages/AdminMembers"; import AdminMembers from "./pages/AdminMembers";
import AdminMembersView from "./pages/AdminMembersView";
import AdminCreateVote from "./pages/AdminCreateVote";
import PollList from "./pages/PollList";
import './App.css';
export default function App() { export default function App() {
return ( return (
<BrowserRouter> <BrowserRouter>
<nav style={{ padding: "1rem", background: "#f5f5f5" }}> <nav style={{ padding: "1rem", background: "#f5f5f5" }}>
<Link to="/">Home</Link> | <Link to="/admin-members">Admin Members</Link> <Link to="/">Home</Link> |
<Link to="/admin-login">Admin Login</Link> |
{/* Member dropdown */}
<div className="dropdown">
<button className="dropbtn">Member </button>
<div className="dropdown-content">
<a href="/admin-members">Upload Members</a>
<a href="/admin-members-view">View Members</a>
</div>
</div> |
<div className="dropdown">
<button className="dropbtn">Vote </button>
<div className="dropdown-content">
<a href="/create-vote">Create Vote</a>
<a href="/polls">Poll List</a>
</div>
</div>
</nav> </nav>
<Routes> <Routes>
<Route path="/" element={<Home />} /> <Route path="/" element={<Home />} />
<Route path="/admin-login" element={<AdminLogin />} />
{/* Member routes */}
<Route path="/admin-members" element={<AdminMembers />} /> <Route path="/admin-members" element={<AdminMembers />} />
<Route path="/admin-members-view" element={<AdminMembersView />} />
{/* Vote routes */}
<Route path="/create-vote" element={<AdminCreateVote />} />
<Route path="/polls" element={<PollList />} />
</Routes> </Routes>
</BrowserRouter> </BrowserRouter>
); );

View File

@@ -0,0 +1,67 @@
import React, { useState } from 'react';
function AdminCreateVote() {
const [question, setQuestion] = useState('');
const [expiresInHours, setExpiresInHours] = useState('');
const [status, setStatus] = useState("");
const handleSubmit = async (e) => {
e.preventDefault();
const formData = new FormData();
formData.append("question", question);
formData.append("expiresInHours", expiresInHours);
try {
const resp = await fetch("/api/admin/new-vote", {
method: "POST",
body: formData,
});
const data = await resp.json();
if (data.success) {
setStatus(`✅ Vote created with ID`);
} else {
setStatus(`❌ Server error: ${data.error}`);
}
} catch (error) {
setStatus("❌ Failed to create vote. Please try again: " + (error.response?.data?.error || error.message));
}
};
return (
<div>
<h1>Create New Vote</h1>
<form onSubmit={handleSubmit}>
<div>
<label>Question:</label>
<input
type="text"
value={question}
onChange={(e) => setQuestion(e.target.value)}
required
/>
</div>
<div>
<label>Expires In (hours):</label>
<input
type="number"
min="1"
value={expiresInHours}
onChange={(e) => setExpiresInHours(e.target.value)}
required
/>
</div>
<button type="submit">Create Vote</button>
</form>
{status && <p style={{ marginTop: "1rem" }}>{status}</p>}
</div>
);
}
export default AdminCreateVote;

View File

@@ -0,0 +1,137 @@
import React, { useState } from "react";
import { useNavigate } from "react-router";
export default function AdminLogin() {
const [username, setUsername] = useState("");
const [password, setPassword] = useState("");
const [error, setError] = useState("");
const [isLoading, setIsLoading] = useState(false);
const navigate = useNavigate();
const handleSubmit = async (e) => {
e.preventDefault();
setError("");
setIsLoading(true);
if (!username || !password) {
setError("⚠️ Please enter both username and password.");
setIsLoading(false);
return;
}
try {
const resp = await fetch("/api/admin/login", {
method: "POST",
headers: {
"Content-Type": "application/json",
},
body: JSON.stringify({
username,
password,
}),
});
const data = await resp.json();
if (resp.ok && data.success) {
// Store the auth token in localStorage
localStorage.setItem("adminToken", data.token);
setError("");
navigate("/admin-members");
} else {
setError(`${data.error || "Login failed"}`);
}
} catch (err) {
setError(`❌ Network error: ${err.message}`);
} finally {
setIsLoading(false);
}
};
return (
<div
style={{
padding: "2rem",
maxWidth: "400px",
margin: "5rem auto",
border: "1px solid #ddd",
borderRadius: "8px",
boxShadow: "0 2px 4px rgba(0,0,0,0.1)",
}}
>
<h2 style={{ textAlign: "center", marginBottom: "2rem" }}>Admin Login</h2>
<form onSubmit={handleSubmit}>
<div style={{ marginBottom: "1rem" }}>
<label htmlFor="username">Username:</label>
<input
id="username"
type="text"
value={username}
onChange={(e) => setUsername(e.target.value)}
style={{
width: "100%",
padding: "0.5rem",
marginTop: "0.5rem",
border: "1px solid #ccc",
borderRadius: "4px",
boxSizing: "border-box",
}}
placeholder="Enter your username"
/>
</div>
<div style={{ marginBottom: "1.5rem" }}>
<label htmlFor="password">Password:</label>
<input
id="password"
type="password"
value={password}
onChange={(e) => setPassword(e.target.value)}
style={{
width: "100%",
padding: "0.5rem",
marginTop: "0.5rem",
border: "1px solid #ccc",
borderRadius: "4px",
boxSizing: "border-box",
}}
placeholder="Enter your password"
/>
</div>
{error && (
<div
style={{
padding: "1rem",
marginBottom: "1rem",
backgroundColor: "#ffe0e0",
border: "1px solid #ff6b6b",
borderRadius: "4px",
color: "#c92a2a",
}}
>
{error}
</div>
)}
<button
type="submit"
disabled={isLoading}
style={{
width: "100%",
padding: "0.75rem",
backgroundColor: isLoading ? "#ccc" : "#007bff",
color: "white",
border: "none",
borderRadius: "4px",
cursor: isLoading ? "not-allowed" : "pointer",
fontSize: "1rem",
fontWeight: "bold",
}}
>
{isLoading ? "Logging in..." : "Login"}
</button>
</form>
</div>
);
}

View File

@@ -1,10 +1,22 @@
import React, { useState } from "react"; import React, { useState, useEffect } from "react";
import { useNavigate } from 'react-router';
export default function AdminMembers() { export default function AdminMembers() {
const [year, setYear] = useState(""); const [year, setYear] = useState("");
const [file, setFile] = useState(null); const [file, setFile] = useState(null);
const [status, setStatus] = useState(""); const [status, setStatus] = useState("");
const navigate = useNavigate();
const isAdmin = () => {
return localStorage.getItem('adminToken') !== null;
};
if (!isAdmin()) {
navigate('/admin-login');
return <div>Redirecting...</div>;
}
const handleSubmit = async (e) => { const handleSubmit = async (e) => {
e.preventDefault(); e.preventDefault();

View File

@@ -0,0 +1,85 @@
import React, { useState } from "react";
import { useNavigate } from 'react-router';
import Table from '@mui/material/Table';
export default function AdminMembersView() {
const [year, setYear] = useState("");
const [members, setMembers] = useState([]);
const [status, setStatus] = useState("");
const navigate = useNavigate();
const isAdmin = () => {
return localStorage.getItem('adminToken') !== null;
};
if (!isAdmin()) {
navigate('/admin-login');
return <div>Redirecting...</div>;
}
const handleSubmit = async (e) => {
e.preventDefault();
try {
const resp = await fetch(`/api/admin/members/view?year=${year}`);
const data = await resp.json();
if (data.success) {
setMembers(data.members);
} else {
setStatus(`❌ Server error: ${data.error}`);
}
} catch (err) {
setStatus(`❌ Network error: ${err.message}`);
}
};
return (
<div style={{ padding: "2rem" }}>
<h2>View Members</h2>
<form onSubmit={handleSubmit}>
<div style={{ marginBottom: "1rem" }}>
<label htmlFor="year">Year:</label>
<input
type="number"
id="year"
name="year"
value={year}
onChange={(e) => setYear(e.target.value)}
required
min="1900"
max="2100"
style={{ width: "150px", padding: "0.3rem" }}
/>
</div>
<button type="submit" style={{ padding: "0.5rem 1rem" }}>
View Members
</button>
</form>
{members.length > 0 && (
<Table>
<thead>
<tr>
<th>Name</th>
<th>Email</th>
</tr>
</thead>
<tbody>
{members.map((member, index) => (
<tr key={index}>
<td>{member.Name}</td>
<td>{member.Email}</td>
</tr>
))}
</tbody>
</Table>
)}
{status && <p style={{ marginTop: "1rem" }}>{status}</p>}
</div>
);
}

View File

@@ -0,0 +1,46 @@
import React, { useEffect, useState } from 'react';
import axios from 'axios';
import Table from '@mui/material/Table';
export default function PollList() {
const [polls, setPolls] = useState([]);
useEffect(() => {
fetchPolls();
}, []);
const fetchPolls = async () => {
try {
const response = await axios.post('/api/admin/view-votes');
setPolls(response.data);
} catch (error) {
console.error('Error fetching polls:', error);
}
};
return (
<div>
<h1>Poll List</h1>
<Table>
<thead>
<tr>
<th>Created At</th>
<th>Question</th>
<th>Member Yes Votes</th>
<th>Member No Votes</th>
</tr>
</thead>
<tbody>
{polls.map((poll) => (
<tr key={poll.id}>
<td>{new Date(poll.created_at).toLocaleString()}</td>
<td>{poll.question}</td>
<td>{poll.member_yes}</td>
<td>{poll.member_no}</td>
</tr>
))}
</tbody>
</Table>
</div>
);
}

1
go.mod
View File

@@ -4,6 +4,7 @@ go 1.24.4
require ( require (
github.com/glebarez/go-sqlite v1.22.0 github.com/glebarez/go-sqlite v1.22.0
github.com/golang-jwt/jwt/v5 v5.2.0
github.com/gorilla/mux v1.8.1 github.com/gorilla/mux v1.8.1
github.com/pkg/errors v0.9.1 github.com/pkg/errors v0.9.1
github.com/stretchr/testify v1.11.1 github.com/stretchr/testify v1.11.1

2
go.sum
View File

@@ -4,6 +4,8 @@ github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkp
github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto= github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto=
github.com/glebarez/go-sqlite v1.22.0 h1:uAcMJhaA6r3LHMTFgP0SifzgXg46yJkgxqyuyec+ruQ= github.com/glebarez/go-sqlite v1.22.0 h1:uAcMJhaA6r3LHMTFgP0SifzgXg46yJkgxqyuyec+ruQ=
github.com/glebarez/go-sqlite v1.22.0/go.mod h1:PlBIdHe0+aUEFn+r2/uthrWq4FxbzugL0L8Li6yQJbc= github.com/glebarez/go-sqlite v1.22.0/go.mod h1:PlBIdHe0+aUEFn+r2/uthrWq4FxbzugL0L8Li6yQJbc=
github.com/golang-jwt/jwt/v5 v5.2.0 h1:d/ix8ftRUorsN+5eMIlF4T6J8CAt9rch3My2winC1Jw=
github.com/golang-jwt/jwt/v5 v5.2.0/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk=
github.com/google/pprof v0.0.0-20221118152302-e6195bd50e26 h1:Xim43kblpZXfIBQsbuBVKCudVG457BR2GZFIz3uw3hQ= github.com/google/pprof v0.0.0-20221118152302-e6195bd50e26 h1:Xim43kblpZXfIBQsbuBVKCudVG457BR2GZFIz3uw3hQ=
github.com/google/pprof v0.0.0-20221118152302-e6195bd50e26/go.mod h1:dDKJzRmX4S37WGHujM7tX//fmj1uioxKzKxz3lo4HJo= github.com/google/pprof v0.0.0-20221118152302-e6195bd50e26/go.mod h1:dDKJzRmX4S37WGHujM7tX//fmj1uioxKzKxz3lo4HJo=
github.com/google/uuid v1.5.0 h1:1p67kYwdtXjb0gL0BPiP1Av9wiZPo5A8z2cWkTZ+eyU= github.com/google/uuid v1.5.0 h1:1p67kYwdtXjb0gL0BPiP1Av9wiZPo5A8z2cWkTZ+eyU=

11
server/common/common.go Normal file
View File

@@ -0,0 +1,11 @@
package common
import (
"encoding/json"
"net/http"
)
func SendError(w http.ResponseWriter, errStr string, statusCode int) {
w.WriteHeader(statusCode)
json.NewEncoder(w).Encode(map[string]string{"error": errStr})
}

View File

@@ -2,7 +2,6 @@ package main
import ( import (
"encoding/json" "encoding/json"
"io/ioutil"
"log" "log"
"net/http" "net/http"
"os" "os"
@@ -10,32 +9,33 @@ import (
"path/filepath" "path/filepath"
"github.com/gorilla/mux" "github.com/gorilla/mux"
"go-sjles-pta-vote/server/common"
"go-sjles-pta-vote/server/models" "go-sjles-pta-vote/server/models"
"go-sjles-pta-vote/server/services" "go-sjles-pta-vote/server/services"
) )
func voteHandler(w http.ResponseWriter, r *http.Request) { func voteHandler(resWriter http.ResponseWriter, request *http.Request) {
var vote models.Vote var vote models.Vote
if err := json.NewDecoder(r.Body).Decode(&vote); err != nil { if err := json.NewDecoder(request.Body).Decode(&vote); err != nil {
http.Error(w, "Invalid request payload", http.StatusBadRequest) common.SendError(resWriter, "Invalid JSON", http.StatusBadRequest)
return return
} }
err := services.SetVote(&vote) if err := services.SetVote(&vote); err != nil {
if err != nil { common.SendError(resWriter, "Failed to set vote", http.StatusInternalServerError)
http.Error(w, err.Error(), http.StatusInternalServerError)
return return
} }
w.WriteHeader(http.StatusOK) resWriter.WriteHeader(http.StatusOK)
} }
func voteIDHandler(w http.ResponseWriter, r *http.Request) { func voteIDHandler(resWriter http.ResponseWriter, request *http.Request) {
vars := mux.Vars(r) vars := mux.Vars(request)
idStr := vars["id"] idStr := vars["id"]
id, err := strconv.ParseInt(idStr, 10, 64) id, err := strconv.ParseInt(idStr, 10, 64)
if err != nil { if err != nil {
http.Error(w, "Invalid poll ID", http.StatusBadRequest) common.SendError(resWriter, "Invalid poll ID", http.StatusBadRequest)
return return
} }
@@ -47,104 +47,82 @@ func voteIDHandler(w http.ResponseWriter, r *http.Request) {
err = services.SetVote(&vote) err = services.SetVote(&vote)
if err != nil { if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError) common.SendError(resWriter, "Failed to set vote", http.StatusInternalServerError)
return return
} }
w.WriteHeader(http.StatusOK) resWriter.WriteHeader(http.StatusOK)
} }
func statsHandler(w http.ResponseWriter, r *http.Request) { func statsHandler(resWriter http.ResponseWriter, request *http.Request) {
if r.Method == "GET" { if request.Method == http.MethodGet {
filePath := "./server/templates/stats.html" filePath := "./server/templates/stats.html"
http.ServeFile(w, r, filePath) http.ServeFile(resWriter, request, filePath)
} else if r.Method == "POST" { } else if request.Method == http.MethodPost {
vars := mux.Vars(r) vars := mux.Vars(request)
id := vars["id"] id := vars["id"]
poll, err := services.GetPollByQuestion(id) poll, err := services.GetPollByQuestion(id)
if err != nil { if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError) common.SendError(resWriter, "Failed to get poll", http.StatusInternalServerError)
return return
} }
json.NewEncoder(w).Encode(poll) json.NewEncoder(resWriter).Encode(poll)
} else { } else {
w.WriteHeader(http.StatusMethodNotAllowed) resWriter.WriteHeader(http.StatusMethodNotAllowed)
} }
} }
func statsIDHandler(w http.ResponseWriter, r *http.Request) { func statsIDHandler(resWriter http.ResponseWriter, request *http.Request) {
vars := mux.Vars(r) vars := mux.Vars(request)
id := vars["id"] id := vars["id"]
poll, err := services.GetPollByQuestion(id) poll, err := services.GetPollByQuestion(id)
if err != nil { if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError) common.SendError(resWriter, "Failed to get poll", http.StatusInternalServerError)
return return
} }
json.NewEncoder(w).Encode(poll) json.NewEncoder(resWriter).Encode(poll)
} }
func adminHandler(w http.ResponseWriter, r *http.Request) { func adminLoginHandler(resWriter http.ResponseWriter, request *http.Request) {
// Add admin functionality here if request.Method != http.MethodPost {
w.WriteHeader(http.StatusOK) common.SendError(resWriter, "Method not allowed", http.StatusMethodNotAllowed)
}
func adminIDHandler(w http.ResponseWriter, r *http.Request) {
//vars := mux.Vars(r)
//id := vars["id"]
// Add admin functionality here
w.WriteHeader(http.StatusOK)
}
func adminMembersHandler(w http.ResponseWriter, r *http.Request) {
if r.Method != http.MethodPost {
w.WriteHeader(http.StatusMethodNotAllowed)
return return
} }
var year int var loginReq services.LoginRequest
var err error if err := json.NewDecoder(request.Body).Decode(&loginReq); err != nil {
common.SendError(resWriter, "Invalid JSON", http.StatusBadRequest)
if err = r.ParseMultipartForm(10 << 20); err != nil {
http.Error(w, "Failed to parse multipart form", http.StatusBadRequest)
return return
} }
year_from_form := r.FormValue("year") // Validate admin credentials
if year_from_form == "" { isValid, err := services.ValidateAdminLogin(loginReq.Username, loginReq.Password)
http.Error(w, "Year is required", http.StatusBadRequest) if err != nil {
return common.SendError(resWriter, "Invalid username or password", http.StatusBadRequest)
} else {
year, err = strconv.Atoi(year_from_form)
if err != nil {
http.Error(w, "Invalid year", http.StatusBadRequest)
return
}
}
if file, _, err := r.FormFile("members.csv"); err != nil {
http.Error(w, "Failed to upload file", http.StatusBadRequest)
return
}
defer file.Close()
if fileBytes, err := ioutil.ReadAll(file); err != nil {
http.Error(w, "Failed to read file", http.StatusInternalServerError)
return return
} }
if err = services.ParseMembersFromBytes(year, fileBytes); err != nil { if !isValid {
w.WriteHeader(http.StatusBadRequest) common.SendError(resWriter, "Invalid username or password", http.StatusUnauthorized)
json.NewEncoder(w).Encode(map[string]string{"error": err.Error()})
return return
} }
w.WriteHeader(http.StatusOK) // Generate JWT token
json.NewEncoder(w).Encode(map[string]bool{"success": true}) token, err := services.GenerateAuthToken(loginReq.Username)
if err != nil {
common.SendError(resWriter, "Failed to generate auth token", http.StatusInternalServerError)
return
}
resWriter.WriteHeader(http.StatusOK)
json.NewEncoder(resWriter).Encode(services.LoginResponse{
Success: true,
Token: token,
})
} }
func main() { func main() {
@@ -155,9 +133,11 @@ func main() {
http.HandleFunc("/api/vote/{id}", voteIDHandler) http.HandleFunc("/api/vote/{id}", voteIDHandler)
http.HandleFunc("/api/stats", statsHandler) http.HandleFunc("/api/stats", statsHandler)
http.HandleFunc("/api/stats/{id}", statsIDHandler) http.HandleFunc("/api/stats/{id}", statsIDHandler)
http.HandleFunc("/api/admin", adminHandler) http.HandleFunc("/api/admin/new-vote", services.AdminNewVoteHandler)
http.HandleFunc("/api/admin/{id}", adminIDHandler) http.HandleFunc("/api/admin/view-votes", services.AdminViewVoteHandler)
http.HandleFunc("/api/admin/members", adminMembersHandler) http.HandleFunc("/api/admin/login", adminLoginHandler)
http.HandleFunc("/api/admin/members", services.AdminMembersHandler)
http.HandleFunc("/api/admin/members/view", services.AdminMembersView)
buildPath := filepath.Join(".", "client", "build") buildPath := filepath.Join(".", "client", "build")
fs := http.FileServer(http.Dir(buildPath)) fs := http.FileServer(http.Dir(buildPath))

127
server/services/auth.go Normal file
View File

@@ -0,0 +1,127 @@
package services
import (
"crypto/sha256"
"encoding/hex"
"log"
"os"
"strings"
"time"
"github.com/golang-jwt/jwt/v5"
"github.com/pkg/errors"
)
type LoginRequest struct {
Username string `json:"username"`
Password string `json:"password"`
}
type LoginResponse struct {
Success bool `json:"success"`
Token string `json:"token,omitempty"`
Error string `json:"error,omitempty"`
}
var jwtSecret string
func init() {
jwtSecret = os.Getenv("JWT_SECRET")
if jwtSecret == "" {
jwtSecret = "your-secret-key-change-in-production"
log.Println("WARNING: JWT_SECRET not set, using default value. Change this in production!")
}
}
// GetAdminCredentials retrieves admin credentials from environment variables
// Format: ADMIN_USERS=username:password|username2:password2
func getAdminCredentials() map[string]string {
adminUsers := os.Getenv("ADMIN_USERS")
if adminUsers == "" {
// Default admin user (change in production)
adminUsers = "admin:admin"
log.Println("WARNING: ADMIN_USERS not set, using default admin:admin")
}
credentials := make(map[string]string)
for _, userPass := range strings.Split(adminUsers, "|") {
parts := strings.Split(strings.TrimSpace(userPass), ":")
if len(parts) == 2 {
credentials[parts[0]] = parts[1]
}
}
return credentials
}
// hashPassword hashes a password using SHA256
func hashPassword(password string) string {
hash := sha256.Sum256([]byte(password))
return hex.EncodeToString(hash[:])
}
// ValidateAdminLogin checks if the provided username and password are valid
func ValidateAdminLogin(username, password string) (bool, error) {
if username == "" || password == "" {
return false, errors.New("username and password are required")
}
credentials := getAdminCredentials()
storedPassword, exists := credentials[username]
if !exists {
// Return false but not an error for security reasons (don't reveal if user exists)
return false, nil
}
// Compare passwords (you could enhance this with bcrypt in production)
if storedPassword != password {
return false, nil
}
return true, nil
}
// GenerateAuthToken generates a JWT token for an authenticated admin user
func GenerateAuthToken(username string) (string, error) {
claims := jwt.MapClaims{
"username": username,
"exp": time.Now().Add(time.Hour * 24).Unix(), // Token expires in 24 hours
"iat": time.Now().Unix(),
}
token := jwt.NewWithClaims(jwt.SigningMethodHS256, claims)
tokenString, err := token.SignedString([]byte(jwtSecret))
if err != nil {
return "", errors.Wrap(err, "failed to generate token")
}
return tokenString, nil
}
// VerifyAuthToken verifies a JWT token and returns the username if valid
func VerifyAuthToken(tokenString string) (string, error) {
token, err := jwt.ParseWithClaims(tokenString, &jwt.MapClaims{}, func(token *jwt.Token) (interface{}, error) {
return []byte(jwtSecret), nil
})
if err != nil {
return "", errors.Wrap(err, "failed to parse token")
}
if !token.Valid {
return "", errors.New("invalid token")
}
claims, ok := token.Claims.(*jwt.MapClaims)
if !ok {
return "", errors.New("invalid token claims")
}
username, ok := (*claims)["username"].(string)
if !ok {
return "", errors.New("username not found in token")
}
return username, nil
}

236
server/services/members.go Normal file
View File

@@ -0,0 +1,236 @@
package services
import (
"encoding/csv"
"fmt"
"log"
"strings"
"net/http"
"strconv"
"io/ioutil"
"encoding/json"
"github.com/pkg/errors"
"go-sjles-pta-vote/server/common"
"go-sjles-pta-vote/server/db"
)
type Member struct {
Name string
Email string
}
const BATCH_SIZE = 100
func AdminMembersHandler(resWriter http.ResponseWriter, request *http.Request) {
if request.Method != http.MethodPost {
resWriter.WriteHeader(http.StatusMethodNotAllowed)
return
}
var year int
var err error
if err = request.ParseMultipartForm(10 << 20); err != nil {
common.SendError(resWriter, "Failed to parse multipart form", http.StatusBadRequest)
return
}
year_from_form := request.FormValue("year")
if year_from_form == "" {
common.SendError(resWriter, "Year is required", http.StatusBadRequest)
return
} else {
year, err = strconv.Atoi(year_from_form)
if err != nil {
common.SendError(resWriter, "Invalid year", http.StatusBadRequest)
return
}
}
file, _, err := request.FormFile("members.csv")
if err != nil {
common.SendError(resWriter, "Failed to read members.csv file", http.StatusBadRequest)
return
}
defer file.Close()
fileBytes, err := ioutil.ReadAll(file)
if err != nil {
common.SendError(resWriter, "Failed to read members.csv file", http.StatusInternalServerError)
return
}
if err = ParseMembersFromBytes(year, fileBytes); err != nil {
common.SendError(resWriter, "Failed to parse members from CSV", http.StatusBadRequest)
return
}
resWriter.WriteHeader(http.StatusOK)
json.NewEncoder(resWriter).Encode(map[string]bool{"success": true})
}
func AdminMembersView(resWriter http.ResponseWriter, request *http.Request) {
yearStr := request.URL.Query().Get("year")
if yearStr == "" {
common.SendError(resWriter, "Year is required", http.StatusBadRequest)
return
}
year, err := strconv.Atoi(yearStr)
if err != nil {
common.SendError(resWriter, "Invalid year", http.StatusBadRequest)
return
}
members, err := GetMembersByYear(year)
if err != nil {
common.SendError(resWriter, "Failed to get members", http.StatusInternalServerError)
return
}
resWriter.WriteHeader(http.StatusOK)
json.NewEncoder(resWriter).Encode(map[string]interface{}{
"success": true,
"members": members,
})
}
func ParseMembersFromBytes(year int, fileBytes []byte) error {
reader := csv.NewReader(strings.NewReader(string(fileBytes)))
reader.FieldsPerRecord = -1 // Allow variable number of fields per record
records, err := reader.ReadAll()
if err != nil {
return errors.Wrap(err, "failed to read CSV from bytes")
}
var members []Member
for i, record := range records {
if i == 0 {
continue // Skip the first line (column headers)
}
if len(record) < 4 {
continue
}
firstName := strings.TrimSpace(record[1])
lastName := strings.TrimSpace(record[2])
email := strings.TrimSpace(record[3])
members = append(members, Member{
Name: fmt.Sprintf("%s %s", firstName, lastName),
Email: email,
})
if len(record) < 30 {
continue
}
email2 := strings.TrimSpace(record[27])
if email2 != "" {
firstName2 := strings.TrimSpace(record[29])
lastName2 := strings.TrimSpace(record[28])
members = append(members, Member{
Name: fmt.Sprintf("%s %s", firstName2, lastName2),
Email: email2,
})
}
}
return saveMember(year, members)
}
func saveMember(year int, members []Member) error {
insertMembersQuery := `
INSERT OR REPLACE INTO members (email, member_name, school_year)
VALUES ($1, $2, $3)
`
log.Printf("Starting to save %d members for year %d", len(members), year)
db_conn, err := db.Connect()
if err != nil {
return errors.Wrap(err, "failed to connect to database")
}
defer db_conn.Close()
tx, err := db_conn.Begin()
if err != nil {
return errors.Wrap(err, "failed to begin transaction")
}
stmt, err := tx.Prepare(insertMembersQuery)
if err != nil {
tx.Rollback()
return errors.Wrap(err, "failed to prepare statement")
}
defer stmt.Close()
for index, member := range members {
_, err = stmt.Exec(member.Email, member.Name, year)
if err != nil {
tx.Rollback()
return errors.Wrap(err, "failed to execute insert")
}
if (index+1) % BATCH_SIZE == 0 {
err = tx.Commit()
if err != nil {
tx.Rollback()
return errors.Wrap(err, "failed to commit transaction")
}
tx, err = db_conn.Begin()
if err != nil {
return errors.Wrap(err, "failed to begin new transaction")
}
stmt, err = tx.Prepare(insertMembersQuery)
if err != nil {
tx.Rollback()
return errors.Wrap(err, "failed to prepare new statement")
}
}
}
return tx.Commit()
}
func GetMembersByYear(year int) ([]Member, error) {
query := `
SELECT member_name, email
FROM members
WHERE school_year = $1
ORDER BY member_name ASC
`
db_conn, err := db.Connect()
if err != nil {
return nil, errors.Wrap(err, "failed to connect to database")
}
defer db_conn.Close()
rows, err := db_conn.Query(query, year)
if err != nil {
return nil, errors.Wrap(err, "failed to execute query")
}
defer rows.Close()
var members []Member
for rows.Next() {
var member Member
if err := rows.Scan(&member.Name, &member.Email); err != nil {
return nil, errors.Wrap(err, "failed to scan row")
}
members = append(members, member)
}
if err := rows.Err(); err != nil {
return nil, errors.Wrap(err, "row iteration error")
}
return members, nil
}

View File

@@ -4,7 +4,12 @@ import (
"database/sql" "database/sql"
"errors" "errors"
"time" "time"
"log"
"encoding/json"
"strconv"
"net/http"
"go-sjles-pta-vote/server/common"
"go-sjles-pta-vote/server/db" "go-sjles-pta-vote/server/db"
"go-sjles-pta-vote/server/models" "go-sjles-pta-vote/server/models"
) )
@@ -13,12 +18,55 @@ var ErrQuestionAlreadyExists = errors.New("Question already exists")
var ErrQuestionDoesntExist = errors.New("Question does not exist yet") var ErrQuestionDoesntExist = errors.New("Question does not exist yet")
var ErrVoterAlreadyVoted = errors.New("Voter already voted") var ErrVoterAlreadyVoted = errors.New("Voter already voted")
var ErrPollNotFound = errors.New("Poll not found") var ErrPollNotFound = errors.New("Poll not found")
var ErrFailedToUpdateVote = errors.New("Failed to update vote")
var ErrFailedToDeletePoll = errors.New("Failed to delete poll")
func CreatePoll(poll *models.Poll) (*models.Poll, error) { const (
new_poll := models.Poll{} DATE_FORMAT = "2006-01-02 15:04:05"
DEFAULT_POLL_DURATION_HOURS = 24
)
func AdminNewVoteHandler(resWriter http.ResponseWriter, request *http.Request) {
if request.Method != http.MethodPost {
resWriter.WriteHeader(http.StatusMethodNotAllowed)
return
}
question := request.FormValue("question")
if question == "" {
common.SendError(resWriter, "Question is required", http.StatusBadRequest)
return
}
durationHours := DEFAULT_POLL_DURATION_HOURS
if durationStr := request.FormValue("duration"); durationStr != "" {
var err error
durationHours, err = strconv.Atoi(durationStr)
if err != nil {
common.SendError(resWriter, "Invalid duration", http.StatusBadRequest)
return
}
}
poll := models.Poll{
Question: question,
ExpiresAt: time.Now().Add(time.Duration(durationHours) * time.Hour).Format(DATE_FORMAT),
}
_, err := CreatePoll(&poll)
if err != nil {
common.SendError(resWriter, "Failed to create poll", http.StatusInternalServerError)
return
}
resWriter.WriteHeader(http.StatusOK)
json.NewEncoder(resWriter).Encode(map[string]bool{"success": true})
}
func CreatePoll(poll *models.Poll) (*int64, error) {
db_conn, err := db.Connect() db_conn, err := db.Connect()
if err != nil { if err != nil {
log.Fatal(err)
return nil, err return nil, err
} }
defer db.Close() defer db.Close()
@@ -29,6 +77,7 @@ func CreatePoll(poll *models.Poll) (*models.Poll, error) {
WHERE question == $1 WHERE question == $1
`) `)
if err != nil { if err != nil {
log.Fatal(err)
return nil, err return nil, err
} }
defer get_stmt.Close() defer get_stmt.Close()
@@ -37,6 +86,7 @@ func CreatePoll(poll *models.Poll) (*models.Poll, error) {
err = get_stmt.QueryRow(poll.Question).Scan(&id) err = get_stmt.QueryRow(poll.Question).Scan(&id)
if err != sql.ErrNoRows { if err != sql.ErrNoRows {
if err != nil { if err != nil {
log.Fatal(err)
return nil, err return nil, err
} }
return nil, ErrQuestionAlreadyExists return nil, ErrQuestionAlreadyExists
@@ -53,6 +103,7 @@ func CreatePoll(poll *models.Poll) (*models.Poll, error) {
`) `)
if err != nil { if err != nil {
log.Fatal(err)
return nil, err return nil, err
} }
@@ -60,19 +111,84 @@ func CreatePoll(poll *models.Poll) (*models.Poll, error) {
res, err := stmt.Exec(poll.Question, poll.ExpiresAt) res, err := stmt.Exec(poll.Question, poll.ExpiresAt)
if err != nil { if err != nil {
log.Fatal(err)
return nil, err return nil, err
} }
new_poll.ID, err = res.LastInsertId() new_poll_id, err := res.LastInsertId()
return &new_poll_id, err
return &new_poll, err }
func AdminViewVoteHandler(resWriter http.ResponseWriter, request *http.Request) {
if request.Method != http.MethodPost {
resWriter.WriteHeader(http.StatusMethodNotAllowed)
return
}
polls, err := GetAllPolls()
if err != nil {
common.SendError(resWriter, "Failed to get polls", http.StatusInternalServerError)
return
}
json.NewEncoder(resWriter).Encode(polls)
}
func GetAllPolls() ([]models.Poll, error) {
db_conn, err := db.Connect()
if err != nil {
log.Fatal(err)
return nil, err
}
defer db.Close()
get_polls_stmt, err := db_conn.Prepare(`
SELECT
id, question,
member_yes_votes, member_no_votes,
non_member_yes_votes, non_member_no_votes,
created_at, updated_at,
expires_at
FROM polls
`)
if err != nil {
log.Fatal(err)
return nil, err
}
defer get_polls_stmt.Close()
rows, err := get_polls_stmt.Query()
if err != nil {
log.Fatal(err)
return nil, err
}
defer rows.Close()
var polls []models.Poll
for rows.Next() {
new_poll := models.Poll{}
err = rows.Scan(
&new_poll.ID, &new_poll.Question,
&new_poll.MemberYes, &new_poll.MemberNo,
&new_poll.NonMemberYes, &new_poll.NonMemberNo,
&new_poll.CreatedAt, &new_poll.UpdatedAt,
&new_poll.ExpiresAt,
)
if err != nil {
log.Fatal(err)
return nil, err
}
polls = append(polls, new_poll)
}
return polls, nil
} }
func GetPollByQuestion(question string) (*models.Poll, error) { func GetPollByQuestion(question string) (*models.Poll, error) {
new_poll := models.Poll{}
db_conn, err := db.Connect() db_conn, err := db.Connect()
if err != nil { if err != nil {
log.Fatal(err)
return nil, err return nil, err
} }
defer db.Close() defer db.Close()
@@ -88,10 +204,12 @@ func GetPollByQuestion(question string) (*models.Poll, error) {
WHERE question == $1 WHERE question == $1
`) `)
if err != nil { if err != nil {
log.Fatal(err)
return nil, err return nil, err
} }
defer get_poll_stmt.Close() defer get_poll_stmt.Close()
new_poll := models.Poll{}
err = get_poll_stmt.QueryRow(question).Scan( err = get_poll_stmt.QueryRow(question).Scan(
&new_poll.ID, &new_poll.Question, &new_poll.ID, &new_poll.Question,
&new_poll.MemberYes, &new_poll.MemberNo, &new_poll.MemberYes, &new_poll.MemberNo,
@@ -103,6 +221,7 @@ func GetPollByQuestion(question string) (*models.Poll, error) {
if err == sql.ErrNoRows { if err == sql.ErrNoRows {
return nil, ErrPollNotFound return nil, ErrPollNotFound
} else if err != nil { } else if err != nil {
log.Fatal(err)
return nil, err return nil, err
} }
@@ -117,11 +236,11 @@ func GetPollByQuestion(question string) (*models.Poll, error) {
defer get_voters_stmt.Close() defer get_voters_stmt.Close()
rows, err := get_voters_stmt.Query(new_poll.ID) rows, err := get_voters_stmt.Query(new_poll.ID)
for rows.Next() { for rows.Next() {
var voter_email string var voter_email string
err = rows.Scan(&voter_email) err = rows.Scan(&voter_email)
if err != nil { if err != nil {
log.Fatal(err)
return nil, err return nil, err
} }
new_poll.WhoVoted = append(new_poll.WhoVoted, voter_email) new_poll.WhoVoted = append(new_poll.WhoVoted, voter_email)
@@ -136,7 +255,7 @@ func GetAndCreatePollByQuestion(question string) (*models.Poll, error) {
if err == ErrPollNotFound { if err == ErrPollNotFound {
create_poll := &models.Poll{ create_poll := &models.Poll{
Question: question, Question: question,
ExpiresAt: time.Now().Add(time.Hour * 10).Format("2006-01-02 15:04:05"), ExpiresAt: time.Now().Add(time.Hour * 10).Format(DATE_FORMAT),
} }
if _, err = CreatePoll(create_poll); err != nil { if _, err = CreatePoll(create_poll); err != nil {
@@ -145,16 +264,17 @@ func GetAndCreatePollByQuestion(question string) (*models.Poll, error) {
return GetPollByQuestion(question) return GetPollByQuestion(question)
} else if err != nil { } else if err != nil {
log.Fatal(err)
return nil, err return nil, err
} else { } else {
return new_poll, err return new_poll, err
} }
} }
// Use models.Vote to set votes
func SetVote(vote *models.Vote) error { func SetVote(vote *models.Vote) error {
db_conn, err := db.Connect() db_conn, err := db.Connect()
if err != nil { if err != nil {
log.Fatal(err)
return err return err
} }
defer db.Close() defer db.Close()
@@ -165,18 +285,21 @@ func SetVote(vote *models.Vote) error {
VALUES ($1, $2) VALUES ($1, $2)
`) `)
if err != nil { if err != nil {
log.Fatal(err)
return err return err
} }
defer set_voter_stmt.Close() defer set_voter_stmt.Close()
res, err := set_voter_stmt.Exec(vote.PollId, vote.Email) res, err := set_voter_stmt.Exec(vote.PollId, vote.Email)
if err != nil { if err != nil {
log.Fatal(err)
return err return err
} else { } else {
rows_changed, err := res.RowsAffected() rows_changed, err := res.RowsAffected()
if rows_changed != 1 { if rows_changed != 1 {
return ErrVoterAlreadyVoted return ErrVoterAlreadyVoted
} else if err != nil { } else if err != nil {
log.Fatal(err)
return err return err
} }
} }
@@ -187,6 +310,7 @@ func SetVote(vote *models.Vote) error {
WHERE email == $1 WHERE email == $1
`) `)
if err != nil { if err != nil {
log.Fatal(err)
return err return err
} }
defer is_voter_member_stmt.Close() defer is_voter_member_stmt.Close()
@@ -197,6 +321,7 @@ func SetVote(vote *models.Vote) error {
if err == sql.ErrNoRows { if err == sql.ErrNoRows {
is_member = false is_member = false
} else if err != nil { } else if err != nil {
log.Fatal(err)
return err return err
} }
@@ -219,18 +344,21 @@ func SetVote(vote *models.Vote) error {
WHERE id == $1 WHERE id == $1
`) `)
if err != nil { if err != nil {
log.Fatal(err)
return err return err
} }
defer add_vote_stmt.Close() defer add_vote_stmt.Close()
res, err = add_vote_stmt.Exec(vote.PollId) res, err = add_vote_stmt.Exec(vote.PollId)
if err != nil { if err != nil {
log.Fatal(err)
return err return err
} }
if num, err := res.RowsAffected(); num != 1 { if num, err := res.RowsAffected(); num != 1 {
return errors.New("Failed to update votes") return ErrFailedToUpdateVote
} else if err != nil { } else if err != nil {
log.Fatal(err)
return err return err
} }
@@ -242,6 +370,7 @@ func DeletePollByQuestion(question string) error {
db_conn, err := db.Connect() db_conn, err := db.Connect()
if err != nil { if err != nil {
return err return err
log.Fatal(err)
} }
defer db.Close() defer db.Close()
@@ -254,12 +383,14 @@ func DeletePollByQuestion(question string) error {
) )
`) `)
if err != nil { if err != nil {
log.Fatal(err)
return err return err
} }
defer delete_votes_stmt.Close() defer delete_votes_stmt.Close()
_, err = delete_votes_stmt.Exec(question) _, err = delete_votes_stmt.Exec(question)
if err != nil { if err != nil {
log.Fatal(err)
return err return err
} }
@@ -268,18 +399,21 @@ func DeletePollByQuestion(question string) error {
WHERE question == $1 WHERE question == $1
`) `)
if err != nil { if err != nil {
log.Fatal(err)
return err return err
} }
defer delete_poll_stmt.Close() defer delete_poll_stmt.Close()
res, err := delete_poll_stmt.Exec(question) res, err := delete_poll_stmt.Exec(question)
if err != nil { if err != nil {
log.Fatal(err)
return err return err
} }
if num, err := res.RowsAffected(); num != 1 { if num, err := res.RowsAffected(); num != 1 {
return errors.New("Failed to delete poll") return ErrFailedToDeletePoll
} else if err != nil { } else if err != nil {
log.Fatal(err)
return err return err
} }

View File

@@ -1,120 +0,0 @@
package services
import (
"encoding/csv"
"fmt"
"log"
"strings"
"github.com/pkg/errors"
"go-sjles-pta-vote/server/db"
)
type Member struct {
Name string
Email string
}
const BATCH_SIZE = 100
func ParseMembersFromBytes(year int, fileBytes []byte) error {
reader := csv.NewReader(strings.NewReader(string(fileBytes)))
reader.FieldsPerRecord = -1 // Allow variable number of fields per record
records, err := reader.ReadAll()
if err != nil {
return errors.Wrap(err, "failed to read CSV from bytes")
}
var members []Member
for i, record := range records {
if i == 0 {
continue // Skip the first line (column headers)
}
if len(record) < 4 {
continue
}
firstName := strings.TrimSpace(record[1])
lastName := strings.TrimSpace(record[2])
email := strings.TrimSpace(record[3])
members = append(members, Member{
Name: fmt.Sprintf("%s %s", firstName, lastName),
Email: email,
})
if len(record) < 30 {
continue
}
email2 := strings.TrimSpace(record[27])
if email2 != "" {
firstName2 := strings.TrimSpace(record[29])
lastName2 := strings.TrimSpace(record[28])
members = append(members, Member{
Name: fmt.Sprintf("%s %s", firstName2, lastName2),
Email: email2,
})
}
}
return saveMember(year, members)
}
func saveMember(year int, members []Member) error {
insertMembersQuery := `
INSERT OR REPLACE INTO members (email, member_name, school_year)
VALUES ($1, $2, $3)
`
log.Printf("Starting to save %d members for year %d", len(members), year)
db_conn, err := db.Connect()
if err != nil {
return errors.Wrap(err, "failed to connect to database")
}
defer db_conn.Close()
tx, err := db_conn.Begin()
if err != nil {
return errors.Wrap(err, "failed to begin transaction")
}
stmt, err := tx.Prepare(insertMembersQuery)
if err != nil {
tx.Rollback()
return errors.Wrap(err, "failed to prepare statement")
}
defer stmt.Close()
for index, member := range members {
_, err = stmt.Exec(member.Email, member.Name, year)
if err != nil {
tx.Rollback()
return errors.Wrap(err, "failed to execute insert")
}
if (index+1) % BATCH_SIZE == 0 {
err = tx.Commit()
if err != nil {
tx.Rollback()
return errors.Wrap(err, "failed to commit transaction")
}
tx, err = db_conn.Begin()
if err != nil {
return errors.Wrap(err, "failed to begin new transaction")
}
stmt, err = tx.Prepare(insertMembersQuery)
if err != nil {
tx.Rollback()
return errors.Wrap(err, "failed to prepare new statement")
}
}
}
return tx.Commit()
}