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
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
|
/* FujiNetChat, an IRC client. Based on NetCat and the old FujiChat. */
#define SELF "FujiNetChat"
#define VERSION "0.0"
#define BANNER SELF " v" VERSION " (B. Watson)\n"
#define DEF_URL "N:TCP://irc.libera.chat:6667"
#define DEF_NICK "FNChatTest"
#define DEF_CHANNEL "##atari"
#include <atari.h>
#include <stdbool.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <ctype.h>
#include <conio.h> // for kbhit() and cgetc()
// #include "conio.h" // our local one.
#include "nio.h"
#include "irc.h"
#include "screen.h"
#include "edbox.h"
char url[256] = DEF_URL; // URL
char usernick[32] = DEF_NICK;
char tmp[8]; // temporary # to string
unsigned char err; // error code of last operation.
unsigned char trip=0; // if trip=1, fujinet is asking us for attention.
bool old_enabled=false; // were interrupts enabled for old vector
void* old_vprced; // old PROCEED vector, restored on exit.
unsigned short rxbuflen;
unsigned int txbuflen; // TX buffer length
/* TODO: user modes (default +iw), fg/bg color... */
extern void ih(); // defined in intr.s
void get_config(void) {
scr_print_current(BANNER);
while(1) {
scr_print_current("URL?\n");
edbox_readline(url, sizeof(url));
scr_print_current("Nick?\n");
edbox_readline(usernick, sizeof(usernick));
/*
scr_print_current("Are these settings OK [Y/n]?\n");
if(tolower(cgetc()) != 'n')
*/
break;
}
}
void txbuf_init(void) {
txbuflen = tx_buf[0] = 0;
}
void txbuf_append_str(const char *str) {
while(*str) {
tx_buf[txbuflen++] = *str++;
}
}
void txbuf_append_str2(const char *s1, const char *s2) {
txbuf_append_str(s1);
txbuf_append_str(s2);
}
void txbuf_append_str3(const char *s1, const char *s2, const char *s3) {
txbuf_append_str(s1);
txbuf_append_str(s2);
txbuf_append_str(s3);
}
void txbuf_set_str(const char *str) {
txbuf_init();
txbuf_append_str(str);
}
void txbuf_set_str2(const char *s1, const char *s2) {
txbuf_set_str(s1);
txbuf_append_str(s2);
}
void txbuf_set_str3(const char *s1, const char *s2, const char *s3) {
txbuf_set_str2(s1, s2);
txbuf_append_str(s3);
}
void txbuf_send(void) {
/* don't sent empty buffer */
if(!txbuflen) return;
/* always terminate with EOL */
if(tx_buf[txbuflen - 1] != '\n')
tx_buf[txbuflen++] = '\n';
nwrite(url, tx_buf, txbuflen);
txbuf_init();
}
void txbuf_send_str(const char *str) {
txbuf_init();
txbuf_append_str(str);
txbuf_send();
}
int fn_connect(void) {
scr_print(SCR_SERVER, "Connecting to: ");
scr_print(SCR_SERVER, url);
scr_print(SCR_SERVER, "\n");
err = nopen(url, FNET_TRANSLATION);
if(err != SUCCESS) {
scr_print(SCR_SERVER, "Connection failed: ");
print_errnum();
return 0;
}
// Open successful, set up interrupt
old_vprced = OS.vprced; // save the old interrupt vector
old_enabled = PIA.pactl & 1; // keep track of old interrupt state
PIA.pactl &= (~1); // Turn off interrupts before changing vector
OS.vprced = ih; // Set PROCEED interrupt vector to our interrupt handler.
PIA.pactl |= 1; // Indicate to PIA we are ready for PROCEED interrupt.
return 1;
}
void fn_disconnect(void) {
// Restore old PROCEED interrupt.
PIA.pactl &= ~1; // disable interrupts
OS.vprced=old_vprced;
PIA.pactl |= old_enabled;
}
int main(void) {
OS.shflok = 0; // turn off shift-lock.
OS.soundr = 0; // Turn off SIO beeping sound
OS.color2 = 0xc0; /* darkest green background */
OS.color1 = 0x0c; /* bright text */
scr_init();
while(1) {
get_config();
edbox_callback = cmd_execute;
if(fn_connect()) {
irc_register();
irc_loop();
fn_disconnect();
}
}
OS.soundr = 3; // Restore SIO beeping sound
return 0;
}
|
