aboutsummaryrefslogtreecommitdiff
path: root/src/main.c
blob: 6de8697cb70e3667f3db19e80a23edefb129817d (plain)
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
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
/* 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"

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 bw=0;            // # of bytes waiting.
unsigned char rx_buf[MAX_IRC_MSG_LEN];      // RX buffer.
unsigned char tx_buf[MAX_IRC_MSG_LEN];      // TX buffer.
unsigned int txbuflen;         // TX buffer length
char channel[32] = DEF_CHANNEL;

/* TODO: user modes (default +iw), fg/bg color... */

extern void ih();               // defined in intr.s

static void strcpy_to_eol(char *dst, const char *src) {
	while(*src && (*src != CH_EOL)) {
		*dst++ = *src++;
	}
	*dst = '\0';
}

/**
 * Get URL from user.
 */
void get_config(void) {
	OS.crsinh = 0;

	putchar(CH_CLR);
	print(BANNER);

	while(1) {
		print("\nURL [");
		print(url);
		print("]?\n");
		get_line(tx_buf, sizeof(url) - 1);
		if(tx_buf[0] != CH_EOL) strcpy_to_eol(url, tx_buf);

		print("Nick [");
		print(usernick);
		print("]? ");
		get_line(tx_buf, sizeof(usernick) - 1);
		if(tx_buf[0] != CH_EOL) strcpy_to_eol(usernick, tx_buf);

		print("Channel [");
		print(channel);
		print("]? ");
		get_line(tx_buf, sizeof(channel) - 1);
		if(tx_buf[0] != CH_EOL) strcpy_to_eol(channel, tx_buf);

		/*
		print("\n\nURL:     ");
		print(url);
		print("\nNick:    ");
		print(usernick);
		print("\nChannel: ");
		print(channel);
		*/

		print("\n\nAre these settings OK [Y/n]? ");
		if(tolower(cgetc()) != 'n') break;
	}

	// print("Press Return to connect\n");
	// cgetc();
}

/**
 * Print error
 */
void print_error(unsigned char err) {
  itoa(err, tmp, 10);
  print(tmp);
  print("\n");
}

void txbuf_init(void) {
	txbuflen = tx_buf[0] = 0;
}

void txbuf_append_str(const char *str) {
	while(*str) {
		tx_buf[txbuflen++] = *str++;
	}
}

void txbuf_set_str(const char *str) {
	txbuf_init();
	txbuf_append_str(str);
}

void txbuf_send(void) {
	if(!txbuflen) return;
	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) {
  print("\n" "Connecting to: ");
  print(url);
  print("\n");

  err = nopen(url, FNET_TRANSLATION);

  if(err != SUCCESS) {
      print("Connection failed: ");
      print_error(err);
      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.lmargn = 0; // Set left margin to 0
  OS.shflok = 0; // turn off shift-lock.
  OS.soundr = 0; // Turn off SIO beeping sound
  cursor(1);     // Keep cursor on

  while(1) {
	  get_config();
	  if(fn_connect()) {
		  irc_register();
		  irc_loop();
		  fn_disconnect();
	  }
  }

  OS.soundr = 3; // Restore SIO beeping sound
  return 0;
}