Skip to content
This repository has been archived by the owner on Oct 7, 2024. It is now read-only.

Commit

Permalink
Merge pull request #23 from NfoAlex/Revert
Browse files Browse the repository at this point in the history
[change] - バージョンのタイムスタンプ差異がいかれた
  • Loading branch information
NfoAlex authored Jun 16, 2023
2 parents 81584a0 + 37a57fd commit 3e206e0
Show file tree
Hide file tree
Showing 2 changed files with 42 additions and 6 deletions.
43 changes: 39 additions & 4 deletions Message.js
Original file line number Diff line number Diff line change
Expand Up @@ -396,8 +396,8 @@ let msgDelete = function msgDelete(dat) {
}
}
*/
console.log("Message :: msgDelete : これから削除");
console.log(dat);
console.log("Message :: msgDelete : これから削除");
console.log(dat);

let t = new Date(); //履歴に時間を追加する用

Expand All @@ -407,7 +407,7 @@ let msgDelete = function msgDelete(dat) {
//メッセージを送るチャンネルの履歴データのディレクトリ
let pathOfJson = "./record/" + dat.channelid + "/" + fulldate + ".json";
let dataHistory = {};
console.log("Message :: msgDelete : 消そうとしているjson -> " + pathOfJson);
//console.log("Message :: msgDelete : 消そうとしているjson -> " + pathOfJson);

//データ取り出し
try{
Expand All @@ -418,6 +418,42 @@ let msgDelete = function msgDelete(dat) {
return -1;
}

//もし添付ファイルがあればファイルを削除
if ( dataHistory[dat.messageid].fileData.isAttatched ) {
let fileDatas = []; //ファイルデータ取り込み
let fileidPathName = ""; //欲しいファイルインデックスのパス
let fileidIndex = {}; //ファイルインデックスのデータ

//削除処理開始
try {
fileDatas = dataHistory[dat.messageid].fileData.attatchmentData;
console.log("Messages :: msgDelete : fileid->",dataHistory[dat.messageid].fileData.attatchmentData);
//ファイルIDからJSON名を取得(日付は複数ファイルでも同じになるはずなのでとりあえず最初を参照)
fileidPathName = fileDatas[0].fileid.slice(0,4) + "_" + fileDatas[0].fileid.slice(4,6) + "_" + fileDatas[0].fileid.slice(6,8);
//ファイルインデックスを取得
fileidIndex = JSON.parse(fs.readFileSync('./fileidIndex/' + dat.channelid + '/' + fileidPathName + '.json', 'utf-8')); //ユーザーデータのJSON読み込み

//ファイルの数だけ処理
for ( let index in fileDatas ) {
//ファイル削除
fs.unlink(__dirname + "/files/" + dat.channelid + "/" + fileidPathName + "/" + fileidIndex[fileDatas[index].fileid].name, (err) => {
//エラー用
if ( err ) console.log(err);

});
//ファイルインデックスJSONからIDを削除
delete fileidIndex[fileDatas[index].fileid];

}

//ファイルインデックスを書き込み
fs.writeFileSync('./fileidIndex/' + dat.channelid + '/' + fileidPathName + '.json', JSON.stringify(fileidIndex, null, 4));
} catch(e) {
console.log("Message :: msgDelete : ファイル削除失敗", e);
}

}

//送信者と削除する人が同じじゃなければ監査ログへ書き込む
if ( dat.reqSender.userid !== dataHistory[dat.messageid].userid ) {
//記録処理
Expand Down Expand Up @@ -542,7 +578,6 @@ let msgRecord = function msgRecord(json) {
fs.writeFileSync(pathOfJson, "{}"); //DBをJSONで保存

}

//ファイルID用JSONにも同じく
try { //JSONの存在確認
//ファイルを読み込んでみる(使いはしない、存在を確認するだけ)
Expand Down
5 changes: 3 additions & 2 deletions index.js
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ const e = require("express");

const port = process.env.PORT || 33333;

const SERVER_VERSION = "alpha_20230614";
const SERVER_VERSION = "alpha_20230616";

const app = express();
const server = http.createServer(app);
Expand Down Expand Up @@ -1401,5 +1401,6 @@ io.on("connection", (socket) => {
//サーバーを開く
server.listen(port, () => {
console.log("*** ver : " + SERVER_VERSION + " ***");
console.log(`Listening on port ${port}`)
console.log(`Listening on port ${port}`);

});

0 comments on commit 3e206e0

Please sign in to comment.