suwako
/
weechat-chatwork
1
0
フォーク 0
コード イシュー プルリクエスト パッケージ プロジェクト リリース Wiki アクティビティ

ファイルを分けた

このコミットが含まれているのは:
守矢諏訪子 2023-08-19 03:02:05 +09:00
親 e327426356
コミット 84991646c0
12個のファイルの変更、328行の追加、239行の削除
統計情報を表示 Patchファイルをダウンロード Diffファイルをダウンロード すべてのファイルを展開 すべてのファイルを折り畳む

4
Makefile
ファイルの表示

@ -8,8 +8,8 @@ LDFLAGS = -shared -lcurl -lcjson
all: $(TARGET)
$(TARGET): main.c
$(CC) $(DEBUG) $(CFLAGS) $(LDFLAGS) -o $@ $<
$(TARGET): commands.c api.c meinfo.c roomsinfo.c rooms.c main.c
$(CC) $(DEBUG) $(CFLAGS) $(LDFLAGS) -o $@ $^
install:
install -d $(LIBDIR)

37
api.c ノーマルファイル
ファイルの表示

@ -0,0 +1,37 @@
#include <stdlib.h>
#include <curl/curl.h>
#include <cjson/cJSON.h>
#include "commands.h"
#include "api.h"
ApiResponse makeApiRequest (const ApiRequest *request) {
ApiResponse response = {0};
CURL *curl = curl_easy_init();
if (!curl) {
return response;
}
Buffer readBuffer = { NULL, 0 };
struct curl_slist *headers = NULL;
char header[256];
snprintf(header, sizeof(header), "X-ChatWorkToken: %s", request->token);
headers = curl_slist_append(headers, header);
curl_easy_setopt(curl, CURLOPT_URL, request->url);
curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, WriteCallback);
curl_easy_setopt(curl, CURLOPT_WRITEDATA, &readBuffer);
response.result = curl_easy_perform(curl);
response.data = cJSON_Parse(readBuffer.data);
free(readBuffer.data);
curl_slist_free_all(headers);
curl_easy_cleanup(curl);
return response;
}

16
api.h ノーマルファイル
ファイルの表示

@ -0,0 +1,16 @@
#ifndef _API_H_
#define _API_H_
typedef struct {
const char *url;
const char *token;
} ApiRequest;
typedef struct {
CURLcode result;
cJSON *data;
} ApiResponse;
ApiResponse makeApiRequest (const ApiRequest *request);
#endif

22
commands.c ノーマルファイル
ファイルの表示

@ -0,0 +1,22 @@
#include <stdlib.h>
#include <string.h>
#include <weechat/weechat-plugin.h>
#include "commands.h"
struct t_config_file *chatwork_config_file = NULL;
struct t_config_option *chatwork_config_token = NULL;
struct t_weechat_plugin *weechat_plugin = NULL;
size_t WriteCallback (void* contents, size_t size, size_t nmemb, void* userp) {
size_t totalSize = size * nmemb;
Buffer *buffer = (Buffer *)userp;
char *temp = realloc(buffer->data, buffer->size + totalSize + 1);
if (temp == NULL) return 0;
buffer->data = temp;
memcpy(buffer->data + buffer->size, contents, totalSize);
buffer->size += totalSize;
buffer->data[buffer->size] = '\0';
return totalSize;
}

15
commands.h ノーマルファイル
ファイルの表示

@ -0,0 +1,15 @@
#ifndef _COMMANDS_H_
#define _COMMANDS_H_
extern struct t_config_file *chatwork_config_file;
extern struct t_config_option *chatwork_config_token;
extern struct t_weechat_plugin *weechat_plugin;
typedef struct {
char *data;
size_t size;
} Buffer;
size_t WriteCallback (void* contents, size_t size, size_t nmemb, void* userp);
#endif

243
main.c
ファイルの表示

@ -6,250 +6,19 @@
#include <curl/curl.h>
#include <cjson/cJSON.h>
#include "commands.h"
#include "api.h"
#include "meinfo.h"
#include "roomsinfo.h"
#include "rooms.h"
WEECHAT_PLUGIN_NAME("chatwork");
WEECHAT_PLUGIN_DESCRIPTION("Chatwork対応");
WEECHAT_PLUGIN_AUTHOR("洩矢諏訪子 <suwako@076.moe>");
WEECHAT_PLUGIN_VERSION("0.1");
WEECHAT_PLUGIN_LICENSE("GPL3");
struct t_config_file *chatwork_config_file = NULL;
struct t_config_option *chatwork_config_token = NULL;
struct t_weechat_plugin *weechat_plugin = NULL;
typedef struct {
const char *url;
const char *token;
} ApiRequest;
typedef struct {
CURLcode result;
cJSON *data;
} ApiResponse;
typedef struct {
char *data;
size_t size;
} Buffer;
size_t WriteCallback (void* contents, size_t size, size_t nmemb, void* userp) {
size_t totalSize = size * nmemb;
Buffer *buffer = (Buffer *)userp;
char *temp = realloc(buffer->data, buffer->size + totalSize + 1);
if (temp == NULL) return 0;
buffer->data = temp;
memcpy(buffer->data + buffer->size, contents, totalSize);
buffer->size += totalSize;
buffer->data[buffer->size] = '\0';
return totalSize;
}
ApiResponse makeApiRequest (const ApiRequest *request) {
ApiResponse response = {0};
CURL *curl = curl_easy_init();
if (!curl) {
return response;
}
Buffer readBuffer = { NULL, 0 };
struct curl_slist *headers = NULL;
char header[256];
snprintf(header, sizeof(header), "X-ChatWorkToken: %s", request->token);
headers = curl_slist_append(headers, header);
curl_easy_setopt(curl, CURLOPT_URL, request->url);
curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, WriteCallback);
curl_easy_setopt(curl, CURLOPT_WRITEDATA, &readBuffer);
response.result = curl_easy_perform(curl);
response.data = cJSON_Parse(readBuffer.data);
free(readBuffer.data);
curl_slist_free_all(headers);
curl_easy_cleanup(curl);
return response;
}
void getMeInfo (struct t_gui_buffer *buffer, const char *token) {
ApiRequest request = {
.url = "https://api.chatwork.com/v2/me",
.token = token,
};
ApiResponse response = makeApiRequest(&request);
if (response.result != CURLE_OK) {
weechat_printf(buffer, "GETリクエストエラー：%s\n", curl_easy_strerror(response.result));
} else {
cJSON *root = response.data;
if (root != NULL) {
const char *name = cJSON_GetObjectItem(root, "name")->valuestring;
weechat_printf(buffer, "GETリクエストに成功：%s\n", name);
} else {
weechat_printf(buffer, "JSONパーシングエラー。\n");
}
cJSON_Delete(root);
}
}
void getRoomsInfo (struct t_gui_buffer *buffer, const char *token) {
ApiRequest request = {
.url = "https://api.chatwork.com/v2/rooms",
.token = token,
};
ApiResponse response = makeApiRequest(&request);
if (response.result != CURLE_OK) {
weechat_printf(buffer, "GETリクエストエラー：%s\n", curl_easy_strerror(response.result));
} else {
cJSON *root = response.data;
if (root != NULL) {
int size = cJSON_GetArraySize(root);
for (int i = 0; i < size; i++) {
cJSON *room = cJSON_GetArrayItem(root, i);
int room_id = cJSON_GetObjectItem(room, "room_id")->valueint;
const char *name = cJSON_GetObjectItem(room, "name")->valuestring;
const char *type = cJSON_GetObjectItem(room, "type")->valuestring;
if (strcmp(type, "my") == 0) {
weechat_printf(buffer, "%d - %s\n", room_id, name);
} else if (strcmp(type, "direct") == 0) {
weechat_printf(buffer, "%d - DM %s\n", room_id, name);
} else if (strcmp(type, "group") == 0) {
weechat_printf(buffer, "%d - グループ %s\n", room_id, name);
}
}
} else {
weechat_printf(buffer, "JSONパーシングエラー。\n");
}
cJSON_Delete(root);
}
}
void populateUserList (struct t_gui_buffer *buffer, const char *token, int room_id) {
char url[256];
snprintf(url, sizeof(url), "https://api.chatwork.com/v2/rooms/%d/members", room_id);
ApiRequest req = {
.url = url,
.token = token,
};
ApiResponse res = makeApiRequest(&req);
if (res.result != CURLE_OK) {
weechat_printf(buffer, "GETリクエストエラー：%s\n", curl_easy_strerror(res.result));
return;
}
cJSON *members = res.data;
if (members != NULL) {
weechat_nicklist_remove_all(buffer);
for (int i = 0; i < cJSON_GetArraySize(members); i++) {
cJSON *member = cJSON_GetArrayItem(members, i);
const char *name = cJSON_GetObjectItem(member, "name")->valuestring;
const char *role = cJSON_GetObjectItem(member, "role")->valuestring;
char *rolepref = NULL;
char *rolecol = NULL;
if (strcmp(role, "admin") == 0) {
rolepref = "@";
rolecol = "weechat.color.*214";
}
weechat_nicklist_add_nick(buffer, NULL, name, "weechat.color.nicklist_nick", rolepref, rolecol, 1);
}
cJSON_Delete(members);
} else {
weechat_printf(buffer, "JSONパーシングエラー。\n");
}
}
void getRoom (struct t_gui_buffer *buffer, const char *token, int room_id) {
char url1[256];
char url2[256];
snprintf(url1, sizeof(url1), "https://api.chatwork.com/v2/rooms/%d", room_id);
snprintf(url2, sizeof(url2), "https://api.chatwork.com/v2/rooms/%d/messages?force=1", room_id);
ApiRequest req = {
.url = url1,
.token = token,
};
ApiResponse res = makeApiRequest(&req);
if (res.result != CURLE_OK) {
weechat_printf(buffer, "GETリクエストエラー：%s\n", curl_easy_strerror(res.result));
} else {
cJSON *bufroot = res.data;
if (bufroot != NULL) {
const char *bufname = cJSON_GetObjectItem(bufroot, "name")->valuestring;
struct t_gui_buffer *buf = weechat_buffer_new(bufname, NULL, NULL, NULL, NULL, NULL, NULL);
cJSON_Delete(bufroot);
populateUserList(buf, token, room_id);
weechat_buffer_set(buf, "display", "1");
weechat_buffer_set(buf, "nicklist", "1");
ApiRequest request = {
.url = url2,
.token = token,
};
ApiResponse response = makeApiRequest(&request);
if (response.result != CURLE_OK) {
weechat_printf(buffer, "GETリクエストエラー：%s\n", curl_easy_strerror(response.result));
} else {
cJSON *root = response.data;
if (root != NULL) {
for (int i = 0; i < cJSON_GetArraySize(root); i++) {
cJSON *message = cJSON_GetArrayItem(root, i);
cJSON *account = cJSON_GetObjectItem(message, "account");
const char *name = cJSON_GetObjectItem(account, "name")->valuestring;
const char *body = cJSON_GetObjectItem(message, "body")->valuestring;
int send_time = cJSON_GetObjectItem(message, "send_time")->valueint;
// send_timeはUnixから日時に
char timestamp[64];
time_t raw_time = send_time;
struct tm *timeinfo = localtime(&raw_time);
strftime(timestamp, sizeof(timestamp), "%Y-%m-%d %H:%M:%S", timeinfo);
char fbody[4096];
// TODO: 返事
//if (sscanf(body, "[To:%d]", &account_id) == 1) {
// weechat_printf(buffer, "%sさんに返事：\n", user);
//} else {
// ファイル共有
if (strstr(body, "[download:") != NULL) {
char download_id[64];
sscanf(body, "[info][title][dtext:file_uploaded][/title][download:%63[^]]]", download_id);
snprintf(fbody, sizeof(fbody), "%s | [ファイル] https://www.chatwork.com/gateway/download_file.php?bin=1&file_id=%s&preview=0", name, download_id);
} else {
snprintf(fbody, sizeof(fbody), "%s | %s", name, body);
}
// TODO: nickはメッセージの前に表示する
weechat_printf_date_tags(buf, raw_time, NULL, "%s\n", fbody);
//} // TODO: 返事
}
} else {
weechat_printf(buffer, "JSONパーシングエラー。\n");
}
cJSON_Delete(root);
}
} else {
weechat_printf(buffer, "JSONパーシングエラー。\n");
}
}
}
int chatwork_command_cb (const void *pointer, void *data, struct t_gui_buffer *buffer, int argc, char **argv, char **argv_eol) {
weechat_printf(buffer, "Chatworkコマンドを実行しました。\n");
const char *token = weechat_config_string(chatwork_config_token);
if (!token || strlen(token) == 0) {
weechat_printf(buffer, "トークンを見つけられませんでした。\n");

39
meinfo.c ノーマルファイル
ファイルの表示

@ -0,0 +1,39 @@
#include <weechat/weechat-plugin.h>
#include <curl/curl.h>
#include <cjson/cJSON.h>
#include "commands.h"
#include "api.h"
#include "meinfo.h"
void getMeInfo (struct t_gui_buffer *buffer, const char *token) {
ApiRequest request = {
.url = "https://api.chatwork.com/v2/me",
.token = token,
};
ApiResponse response = makeApiRequest(&request);
if (response.result != CURLE_OK) {
weechat_printf(buffer, "GETリクエストエラー：%s\n", curl_easy_strerror(response.result));
} else {
cJSON *root = response.data;
if (root != NULL) {
int account_id = cJSON_GetObjectItem(root, "account_id")->valueint;
const char *name = cJSON_GetObjectItem(root, "name")->valuestring;
const char *chatwork_id = cJSON_GetObjectItem(root, "chatwork_id")->valuestring;
int organization_id = cJSON_GetObjectItem(root, "organization_id")->valueint;
const char *organization_name = cJSON_GetObjectItem(root, "organization_name")->valuestring;
const char *department = cJSON_GetObjectItem(root, "department")->valuestring;
weechat_printf(buffer, "アカウントID：%d\n", account_id);
weechat_printf(buffer, "名前：%s\n", name);
weechat_printf(buffer, "チャットワークID：%s\n", chatwork_id);
weechat_printf(buffer, "組織ID：%d\n", organization_id);
weechat_printf(buffer, "組織名：%s\n", organization_name);
weechat_printf(buffer, "部局：%s\n", department);
} else {
weechat_printf(buffer, "JSONパーシングエラー。\n");
}
cJSON_Delete(root);
}
}

6
meinfo.h ノーマルファイル
ファイルの表示

@ -0,0 +1,6 @@
#ifndef _MEINFO_H_
#define _MEINFO_H_
void getMeInfo (struct t_gui_buffer *buffer, const char *token);
#endif

128
rooms.c ノーマルファイル
ファイルの表示

@ -0,0 +1,128 @@
#include <string.h>
#include <time.h>
#include <weechat/weechat-plugin.h>
#include <curl/curl.h>
#include <cjson/cJSON.h>
#include "commands.h"
#include "api.h"
#include "rooms.h"
void populateUserList (struct t_gui_buffer *buffer, const char *token, int room_id) {
char url[256];
snprintf(url, sizeof(url), "https://api.chatwork.com/v2/rooms/%d/members", room_id);
ApiRequest req = {
.url = url,
.token = token,
};
ApiResponse res = makeApiRequest(&req);
if (res.result != CURLE_OK) {
weechat_printf(buffer, "GETリクエストエラー：%s\n", curl_easy_strerror(res.result));
return;
}
cJSON *members = res.data;
if (members != NULL) {
weechat_nicklist_remove_all(buffer);
for (int i = 0; i < cJSON_GetArraySize(members); i++) {
cJSON *member = cJSON_GetArrayItem(members, i);
const char *name = cJSON_GetObjectItem(member, "name")->valuestring;
const char *role = cJSON_GetObjectItem(member, "role")->valuestring;
char *rolepref = NULL;
char *rolecol = NULL;
if (strcmp(role, "admin") == 0) {
rolepref = "@";
rolecol = "weechat.color.*214";
}
weechat_nicklist_add_nick(buffer, NULL, name, "weechat.color.nicklist_nick", rolepref, rolecol, 1);
}
cJSON_Delete(members);
} else {
weechat_printf(buffer, "JSONパーシングエラー。\n");
}
}
void getRoom (struct t_gui_buffer *buffer, const char *token, int room_id) {
char url1[256];
char url2[256];
snprintf(url1, sizeof(url1), "https://api.chatwork.com/v2/rooms/%d", room_id);
snprintf(url2, sizeof(url2), "https://api.chatwork.com/v2/rooms/%d/messages?force=1", room_id);
ApiRequest req = {
.url = url1,
.token = token,
};
ApiResponse res = makeApiRequest(&req);
if (res.result != CURLE_OK) {
weechat_printf(buffer, "GETリクエストエラー：%s\n", curl_easy_strerror(res.result));
} else {
cJSON *bufroot = res.data;
if (bufroot != NULL) {
const char *bufname = cJSON_GetObjectItem(bufroot, "name")->valuestring;
struct t_gui_buffer *buf = weechat_buffer_new(bufname, NULL, NULL, NULL, NULL, NULL, NULL);
cJSON_Delete(bufroot);
populateUserList(buf, token, room_id);
weechat_buffer_set(buf, "display", "1");
weechat_buffer_set(buf, "nicklist", "1");
ApiRequest request = {
.url = url2,
.token = token,
};
ApiResponse response = makeApiRequest(&request);
if (response.result != CURLE_OK) {
weechat_printf(buffer, "GETリクエストエラー：%s\n", curl_easy_strerror(response.result));
} else {
cJSON *root = response.data;
if (root != NULL) {
for (int i = 0; i < cJSON_GetArraySize(root); i++) {
cJSON *message = cJSON_GetArrayItem(root, i);
cJSON *account = cJSON_GetObjectItem(message, "account");
const char *name = cJSON_GetObjectItem(account, "name")->valuestring;
const char *body = cJSON_GetObjectItem(message, "body")->valuestring;
int send_time = cJSON_GetObjectItem(message, "send_time")->valueint;
// send_timeはUnixから日時に
char timestamp[64];
time_t raw_time = send_time;
struct tm *timeinfo = localtime(&raw_time);
strftime(timestamp, sizeof(timestamp), "%Y-%m-%d %H:%M:%S", timeinfo);
char fbody[4096];
// TODO: 返事
//if (sscanf(body, "[To:%d]", &account_id) == 1) {
// weechat_printf(buffer, "%sさんに返事：\n", user);
//} else {
// ファイル共有
if (strstr(body, "[download:") != NULL) {
char download_id[64];
sscanf(body, "[info][title][dtext:file_uploaded][/title][download:%63[^]]]", download_id);
snprintf(fbody, sizeof(fbody), "%s | [ファイル] https://www.chatwork.com/gateway/download_file.php?bin=1&file_id=%s&preview=0", name, download_id);
} else {
snprintf(fbody, sizeof(fbody), "%s | %s", name, body);
}
// TODO: nickはメッセージの前に表示する
weechat_printf_date_tags(buf, raw_time, NULL, "%s\n", fbody);
//} // TODO: 返事
}
} else {
weechat_printf(buffer, "JSONパーシングエラー。\n");
}
cJSON_Delete(root);
}
} else {
weechat_printf(buffer, "JSONパーシングエラー。\n");
}
}
}

7
rooms.h ノーマルファイル
ファイルの表示

@ -0,0 +1,7 @@
#ifndef _ROOMS_H_
#define _ROOMS_H_
void populateUserList (struct t_gui_buffer *buffer, const char *token, int room_id);
void getRoom (struct t_gui_buffer *buffer, const char *token, int room_id);
#endif

44
roomsinfo.c ノーマルファイル
ファイルの表示

@ -0,0 +1,44 @@
#include <string.h>
#include <weechat/weechat-plugin.h>
#include <curl/curl.h>
#include <cjson/cJSON.h>
#include "commands.h"
#include "api.h"
#include "roomsinfo.h"
void getRoomsInfo (struct t_gui_buffer *buffer, const char *token) {
ApiRequest request = {
.url = "https://api.chatwork.com/v2/rooms",
.token = token,
};
ApiResponse response = makeApiRequest(&request);
if (response.result != CURLE_OK) {
weechat_printf(buffer, "GETリクエストエラー：%s\n", curl_easy_strerror(response.result));
} else {
cJSON *root = response.data;
if (root != NULL) {
int size = cJSON_GetArraySize(root);
for (int i = 0; i < size; i++) {
cJSON *room = cJSON_GetArrayItem(root, i);
int room_id = cJSON_GetObjectItem(room, "room_id")->valueint;
const char *name = cJSON_GetObjectItem(room, "name")->valuestring;
const char *type = cJSON_GetObjectItem(room, "type")->valuestring;
if (strcmp(type, "my") == 0) {
weechat_printf(buffer, "%d - %s\n", room_id, name);
} else if (strcmp(type, "direct") == 0) {
weechat_printf(buffer, "%d - DM %s\n", room_id, name);
} else if (strcmp(type, "group") == 0) {
weechat_printf(buffer, "%d - グループ %s\n", room_id, name);
}
}
} else {
weechat_printf(buffer, "JSONパーシングエラー。\n");
}
cJSON_Delete(root);
}
}

6
roomsinfo.h ノーマルファイル
ファイルの表示

@ -0,0 +1,6 @@
#ifndef _ROOMSINFO_H_
#define _ROOMSINFO_H_
void getRoomsInfo (struct t_gui_buffer *buffer, const char *token);
#endif