Merge branch 'master' of git.magickabbs.com:/home/andrew/repositories/MagickaBBS
This commit is contained in:
commit
0cbefa834f
@ -406,6 +406,7 @@ extern char **split_on_space(char *str, size_t *lenp);
|
|||||||
extern void die(const char *msg);
|
extern void die(const char *msg);
|
||||||
extern void *malloz(size_t size);
|
extern void *malloz(size_t size);
|
||||||
extern char *file2str(const char *path);
|
extern char *file2str(const char *path);
|
||||||
|
extern stralloc file2stralloc(const char *path);
|
||||||
extern char *str5dup(const char *a, const char *b, const char *c, const char *d, const char *e);
|
extern char *str5dup(const char *a, const char *b, const char *c, const char *d, const char *e);
|
||||||
extern char *str4dup(const char *a, const char *b, const char *c, const char *d);
|
extern char *str4dup(const char *a, const char *b, const char *c, const char *d);
|
||||||
extern char *str3dup(const char *a, const char *b, const char *c);
|
extern char *str3dup(const char *a, const char *b, const char *c);
|
||||||
|
@ -778,6 +778,7 @@ void bwave_upload_reply() {
|
|||||||
int area;
|
int area;
|
||||||
tWORD msg_attr;
|
tWORD msg_attr;
|
||||||
struct fido_addr addr;
|
struct fido_addr addr;
|
||||||
|
stralloc sa = EMPTY_STRALLOC;
|
||||||
char *body;
|
char *body;
|
||||||
char *tagline;
|
char *tagline;
|
||||||
struct stat s;
|
struct stat s;
|
||||||
@ -1053,20 +1054,20 @@ void bwave_upload_reply() {
|
|||||||
snprintf(originlinebuffer, 256, "\r");
|
snprintf(originlinebuffer, 256, "\r");
|
||||||
}
|
}
|
||||||
|
|
||||||
body = file2str(msgbuffer);
|
sa = file2stralloc(msgbuffer);
|
||||||
if (body == NULL) {
|
if (sa.s == NULL) {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
stralloc_cats(&sa, originlinebuffer);
|
||||||
|
stralloc_0(&sa);
|
||||||
|
body = sa.s;
|
||||||
|
char *p, *s;
|
||||||
|
|
||||||
strcat(body, originlinebuffer);
|
for (p = s = body; *p != '\0'; ++p) {
|
||||||
|
if (*p != '\n')
|
||||||
bpos = 0;
|
*s++ = *p;
|
||||||
for (i = 0; i < strlen(body); i++) {
|
|
||||||
if (body[i] != '\n') {
|
|
||||||
body[bpos++] = body[i];
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
body[bpos] = '\0';
|
*s = '\0';
|
||||||
|
|
||||||
if (bwave_add_message(confr, area, convertl(upl_rec.unix_date), upl_rec.to, upl_rec.subj, &addr, body) != 0) {
|
if (bwave_add_message(confr, area, convertl(upl_rec.unix_date), upl_rec.to, upl_rec.subj, &addr, body) != 0) {
|
||||||
// failed to add message
|
// failed to add message
|
||||||
|
46
src/files.c
46
src/files.c
@ -701,10 +701,10 @@ int do_upload(struct user_record *user, char *final_path) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void upload(struct user_record *user) {
|
void upload(struct user_record *user) {
|
||||||
char buffer[331];
|
stralloc buffer = EMPTY_STRALLOC;
|
||||||
char buffer2[66];
|
char pathname[PATH_MAX];
|
||||||
char buffer3[256];
|
|
||||||
|
|
||||||
int i;
|
int i;
|
||||||
char *create_sql = "CREATE TABLE IF NOT EXISTS files ("
|
char *create_sql = "CREATE TABLE IF NOT EXISTS files ("
|
||||||
@ -735,25 +735,27 @@ void upload(struct user_record *user) {
|
|||||||
description = get_file_id_diz(upload_filename);
|
description = get_file_id_diz(upload_filename);
|
||||||
|
|
||||||
if (description == NULL) {
|
if (description == NULL) {
|
||||||
|
char descbuf[66];
|
||||||
|
|
||||||
s_printf(get_string(199));
|
s_printf(get_string(199));
|
||||||
s_printf(get_string(200));
|
s_printf(get_string(200));
|
||||||
buffer[0] = '\0';
|
|
||||||
for (i = 0; i < 5; i++) {
|
for (i = 0; i < 5; i++) {
|
||||||
s_printf("\r\n%d: ", i);
|
s_printf("\r\n%d: ", i);
|
||||||
s_readstring(buffer2, 65);
|
s_readstring(descbuf, sizeof(descbuf) - 1);
|
||||||
if (strlen(buffer2) == 0) {
|
if (*descbuf == '\0') {
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
strcat(buffer, buffer2);
|
stralloc_cats(&buffer, descbuf);
|
||||||
strcat(buffer, "\n");
|
stralloc_append1(&buffer, '\n');
|
||||||
}
|
}
|
||||||
|
stralloc_0(&buffer);
|
||||||
} else {
|
} else {
|
||||||
s_printf(get_string(201));
|
s_printf(get_string(201));
|
||||||
}
|
}
|
||||||
sprintf(buffer3, "%s/%s.sq3", conf.bbs_path, conf.file_directories[user->cur_file_dir]->file_subs[user->cur_file_sub]->database);
|
snprintf(pathname, sizeof pathname, "%s/%s.sq3",
|
||||||
|
conf.bbs_path, conf.file_directories[user->cur_file_dir]->file_subs[user->cur_file_sub]->database);
|
||||||
|
|
||||||
rc = sqlite3_open(buffer3, &db);
|
rc = sqlite3_open(pathname, &db);
|
||||||
|
|
||||||
if (rc != SQLITE_OK) {
|
if (rc != SQLITE_OK) {
|
||||||
dolog("Cannot open database: %s", sqlite3_errmsg(db));
|
dolog("Cannot open database: %s", sqlite3_errmsg(db));
|
||||||
@ -766,9 +768,8 @@ void upload(struct user_record *user) {
|
|||||||
dolog("SQL error: %s", err_msg);
|
dolog("SQL error: %s", err_msg);
|
||||||
sqlite3_free(err_msg);
|
sqlite3_free(err_msg);
|
||||||
sqlite3_close(db);
|
sqlite3_close(db);
|
||||||
if (description != NULL) {
|
free(description);
|
||||||
free(description);
|
free(buffer.s);
|
||||||
}
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
rc = sqlite3_prepare_v2(db, sql, -1, &res, 0);
|
rc = sqlite3_prepare_v2(db, sql, -1, &res, 0);
|
||||||
@ -778,7 +779,7 @@ void upload(struct user_record *user) {
|
|||||||
|
|
||||||
sqlite3_bind_text(res, 1, upload_filename, -1, 0);
|
sqlite3_bind_text(res, 1, upload_filename, -1, 0);
|
||||||
if (description == NULL) {
|
if (description == NULL) {
|
||||||
sqlite3_bind_text(res, 2, buffer, -1, 0);
|
sqlite3_bind_text(res, 2, buffer.s, -1, 0);
|
||||||
} else {
|
} else {
|
||||||
sqlite3_bind_text(res, 2, description, -1, 0);
|
sqlite3_bind_text(res, 2, description, -1, 0);
|
||||||
}
|
}
|
||||||
@ -789,9 +790,8 @@ void upload(struct user_record *user) {
|
|||||||
dolog("Failed to execute statement: %s", sqlite3_errmsg(db));
|
dolog("Failed to execute statement: %s", sqlite3_errmsg(db));
|
||||||
sqlite3_finalize(res);
|
sqlite3_finalize(res);
|
||||||
sqlite3_close(db);
|
sqlite3_close(db);
|
||||||
if (description != NULL) {
|
free(description);
|
||||||
free(description);
|
free(buffer.s);
|
||||||
}
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -801,16 +801,14 @@ void upload(struct user_record *user) {
|
|||||||
dolog("execution failed: %s", sqlite3_errmsg(db));
|
dolog("execution failed: %s", sqlite3_errmsg(db));
|
||||||
sqlite3_finalize(res);
|
sqlite3_finalize(res);
|
||||||
sqlite3_close(db);
|
sqlite3_close(db);
|
||||||
if (description != NULL) {
|
free(description);
|
||||||
free(description);
|
free(buffer.s);
|
||||||
}
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
sqlite3_finalize(res);
|
sqlite3_finalize(res);
|
||||||
sqlite3_close(db);
|
sqlite3_close(db);
|
||||||
if (description != NULL) {
|
free(description);
|
||||||
free(description);
|
free(buffer.s);
|
||||||
}
|
|
||||||
|
|
||||||
s_printf(get_string(202));
|
s_printf(get_string(202));
|
||||||
s_printf(get_string(6));
|
s_printf(get_string(6));
|
||||||
|
@ -395,7 +395,6 @@ int l_postMessage(lua_State *L) {
|
|||||||
int z;
|
int z;
|
||||||
int j;
|
int j;
|
||||||
int i;
|
int i;
|
||||||
char *msg;
|
|
||||||
char *tagline;
|
char *tagline;
|
||||||
struct utsname name;
|
struct utsname name;
|
||||||
|
|
||||||
@ -514,21 +513,16 @@ int l_postMessage(lua_State *L) {
|
|||||||
snprintf(buffer, 256, "\r--- MagickaBBS v%d.%d%s (%s/%s)\r * Origin: %s \r", VERSION_MAJOR, VERSION_MINOR, VERSION_STR, name.sysname, name.machine, tagline);
|
snprintf(buffer, 256, "\r--- MagickaBBS v%d.%d%s (%s/%s)\r * Origin: %s \r", VERSION_MAJOR, VERSION_MINOR, VERSION_STR, name.sysname, name.machine, tagline);
|
||||||
}
|
}
|
||||||
|
|
||||||
msg = (char *)malloz(strlen(body) + 2 + strlen(buffer));
|
stralloc sa = EMPTY_STRALLOC;
|
||||||
|
stralloc_ready(&sa, strlen(body) + 2 + strlen(buffer));
|
||||||
|
for (char *p = body; *p != '\0'; ++p)
|
||||||
|
if (*p != '\n')
|
||||||
|
stralloc_append1(&sa, *p);
|
||||||
|
stralloc_cats(&sa, buffer);
|
||||||
|
stralloc_0(&sa);
|
||||||
|
char *msg = sa.s;
|
||||||
|
|
||||||
j = 0;
|
if (JAM_AddMessage(jb, &jmh, jsp, msg, strlen(msg))) {
|
||||||
|
|
||||||
for (i = 0; i < strlen(body); i++) {
|
|
||||||
if (body[i] == '\n') {
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
msg[j++] = body[i];
|
|
||||||
}
|
|
||||||
msg[j] = '\0';
|
|
||||||
|
|
||||||
strcat(msg, buffer);
|
|
||||||
|
|
||||||
if (JAM_AddMessage(jb, &jmh, jsp, (char *)msg, strlen(msg))) {
|
|
||||||
dolog("Failed to add message");
|
dolog("Failed to add message");
|
||||||
JAM_UnlockMB(jb);
|
JAM_UnlockMB(jb);
|
||||||
|
|
||||||
@ -536,13 +530,12 @@ int l_postMessage(lua_State *L) {
|
|||||||
JAM_CloseMB(jb);
|
JAM_CloseMB(jb);
|
||||||
free(msg);
|
free(msg);
|
||||||
return 0;
|
return 0;
|
||||||
} else {
|
|
||||||
JAM_UnlockMB(jb);
|
|
||||||
|
|
||||||
JAM_DelSubPacket(jsp);
|
|
||||||
JAM_CloseMB(jb);
|
|
||||||
free(jb);
|
|
||||||
}
|
}
|
||||||
|
JAM_UnlockMB(jb);
|
||||||
|
|
||||||
|
JAM_DelSubPacket(jsp);
|
||||||
|
JAM_CloseMB(jb);
|
||||||
|
free(jb);
|
||||||
free(msg);
|
free(msg);
|
||||||
|
|
||||||
if (conf.mail_conferences[confr]->mail_areas[area]->type == TYPE_ECHOMAIL_AREA || conf.mail_conferences[confr]->mail_areas[area]->type == TYPE_NEWSGROUP_AREA) {
|
if (conf.mail_conferences[confr]->mail_areas[area]->type == TYPE_ECHOMAIL_AREA || conf.mail_conferences[confr]->mail_areas[area]->type == TYPE_NEWSGROUP_AREA) {
|
||||||
|
27
src/util.c
27
src/util.c
@ -1,4 +1,5 @@
|
|||||||
#include <sys/types.h>
|
#include <sys/types.h>
|
||||||
|
#include <sys/mman.h>
|
||||||
#include <sys/stat.h>
|
#include <sys/stat.h>
|
||||||
|
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
@ -45,6 +46,32 @@ char *file2str(const char *path) {
|
|||||||
return contents;
|
return contents;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
stralloc file2stralloc(const char *path) {
|
||||||
|
struct stat s;
|
||||||
|
int fd;
|
||||||
|
|
||||||
|
memset(&s, 0, sizeof(s));
|
||||||
|
if (stat(path, &s) < 0)
|
||||||
|
return EMPTY_STRALLOC;
|
||||||
|
if (!S_ISREG(s.st_mode))
|
||||||
|
return EMPTY_STRALLOC;
|
||||||
|
fd = open(path, O_RDONLY);
|
||||||
|
if (fd < 0)
|
||||||
|
return EMPTY_STRALLOC;
|
||||||
|
size_t len = s.st_size;
|
||||||
|
char *p = mmap(NULL, len, PROT_READ, MAP_SHARED, fd, 0);
|
||||||
|
if (p == NULL) {
|
||||||
|
close(fd);
|
||||||
|
return EMPTY_STRALLOC;
|
||||||
|
}
|
||||||
|
stralloc sa = EMPTY_STRALLOC;
|
||||||
|
stralloc_copyb(&sa, p, len);
|
||||||
|
munmap(fd, len);
|
||||||
|
close(fd);
|
||||||
|
|
||||||
|
return sa;
|
||||||
|
}
|
||||||
|
|
||||||
char *str5dup(const char *a, const char *b, const char *c, const char *d, const char *e) {
|
char *str5dup(const char *a, const char *b, const char *c, const char *d, const char *e) {
|
||||||
char *p;
|
char *p;
|
||||||
size_t alen, blen, clen, dlen, elen;
|
size_t alen, blen, clen, dlen, elen;
|
||||||
|
Reference in New Issue
Block a user