1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
|
HEADER <- 2048
PORT <- 6011
SERVER <- "localhost"
FORMAT <- "utf-8"
DISCONNECT_MESSAGE <- "!DISSCONNECT"
con <- socketConnection(
host = SERVER,
port = PORT,
server = FALSE,
open = "a+b"
)
data_type_vect <- c(
character = 'character',
str = 'character',
integer = 'integer',
int = 'integer',
logical = 'logical',
bool = 'logical'
)
display_msg <- function(msg) {
cat(
'\033[94m',
msg,
sep = '',
end = '\033[0m\n'
)
}
add_missing_bits <- function(bits, base = 8) {
missing_bits <- length(bits) %% base
if (missing_bits > 0) {
missing_bits <- rep(as.raw(00), times = base - missing_bits)
bits <- c(bits, missing_bits)
}
return(bits)
}
bin_conv <- function(data, data_type_name = NA) {
conv_data <- NA
# convert to binary
if (is.character(data) && is.na(data_type_name)) {
conv_data <- charToRaw(data)
conv_data <- rawToBits(conv_data)
} else if (is.integer(data) && is.na(data_type_name)) {
conv_data <- as.raw(data)
conv_data <- rawToBits(conv_data)
# convert from binary
} else if (is.raw(data) && data_type_name == "character") {
conv_data <- add_missing_bits(data)
conv_data <- packBits(conv_data, "raw")
conv_data <- rawToChar(conv_data)
} else if (is.raw(data) && data_type_name == "integer") {
conv_data <- add_missing_bits(data)
conv_data <- packBits(conv_data, "raw")
conv_data <- as.integer(conv_data)
}
return(conv_data)
}
# may not need to pass connection if it will only be 1 per dialogue
send <- function(conn, data, send_data_type = FALSE) {
if (send_data_type) {
data_type_name <- typeof(data)
data_type_name <- bin_conv(data_type_name)
writeBin(data_type_name, conn)
}
bin_data <- bin_conv(data)
writeBin(bin_data, conn)
}
# may not need to pass connection if it will only be 1 per dialogue
# I still want to consolidate the recv_data_type and set_data_type args
recv <- function(conn, recv_data_type = FALSE, set_data_type = "character") {
if (recv_data_type) {
suppressWarnings(data_type_name <- readBin(conn, "raw", HEADER))
while (length(data_type_name) == 0) {
suppressWarnings(data_type_name <- readBin(conn, "raw", HEADER))
}
data_type_name <- bin_conv(data_type_name, "character")
data_type_name <- data_type_vect[data_type_name]
} else {
data_type_name <- set_data_type
}
suppressWarnings(data <- readBin(conn, "raw", HEADER))
while (length(data) == 0) {
suppressWarnings(data <- readBin(conn, "raw", HEADER))
}
data <- bin_conv(data, data_type_name)
return(data)
}
#receive target file path
# need to learn how to receive path as system argument.
# may also receive package directory to source-import R modules
file_path <- recv(con)
#load target file
source(file_path)
confirm <- TRUE
msg <- 'confirm'
while (msg != '!DISCONNECT') {
# there should be several handeling methods
# returning variables
# evaluating expressions
display_msg(msg)
val <- get(msg)
send(con, val, TRUE)
msg <- recv(con, FALSE, "character")
}
close(con)
|
