Mini messenger em Prisma + ig + igRede

Fiz um mensageiro instantâneo bem básico, só para servir de modelo mesmo.

igmsg

PS.: Fiz uma correção no código em relação a variável porta destino, dava erro e fechamento do programa. (25/06 – 22h);

PS.: Novamente corrigido, havia outros erros, código modificado 26/06/17 19:09. Na verdade olhando bem, ainda tem uns bugs e vendo o manual de referência do código C percebi que preciso mexer na lib igrede para acrescentar mais funções importantes, farei isso futuramente.

Segue a última modificação que fiz:

/*Programa Mini messenger em Prisma + igbr + igrede
 * 
 * Licença: MIT
 * 
 Permission is hereby granted, free of charge, to any person obtaining a copy of this 
 software and associated documentation files (the "Software"), to deal in the Software 
 without restriction, including without limitation the rights to use, copy, modify, merge, 
 publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons 
 to whom the Software is furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in all 
copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, 
INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR 
PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE 
FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, 
ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS 
IN THE SOFTWARE. 
 */
 
local _Versao_ = '0.2';

local _Sobre_ = 
'Mini mensageiro instantâneo feito em \
Prisma-1.0.100';

local ig = inclua'igbr';
local rede = inclua'igrede';

funcao principal(arg)
  local t = interface(); 
  t.BLOCO_TAM = '1000000'; //1MB aproxim. 
  ig.loop(); //o mesmo que ig.fimprograma() use qual preferir.
  se t.servidor entao
    rede.servidor_pare(t.servidor);
  fim
  se t.cliente entao
    ig.objeto_desref(t.cliente);//desreferencia o objeto, ou seja, limpa a memória.
  fim
  retorne 0;
fim 

funcao obt_ip_porta(s)
    local url = s:analise(':'); //os dois pontos separa o ip da porta lembra?
    se nao url entao 
      retorne falso, "\nErro: Ip ou porta invalida";
    fim;//abandona a funcao imprimindo o erro.
    local ip = url[1];
    local porta = url[3];//o [2] é o `:';
    retorne {ip=ip,porta=porta};
fim

funcao processe_msg(s)
    local dado = s:analise('\002'); //o ascii code 2 separa o cabeçalho de informação da msg.
    se nao dado entao 
      retorne falso, "\nErro: Ip ou porta invalida";
    fim;//abandona a funcao imprimindo o erro.
    local url = dado[1]
    local msg = dado[3];//o [2] é o `:';
    retorne {url=url,msg=msg};
fim

funcao interface()
  local t = {}; //criando a tabela de componentes.
  t.jan = ig.janela('igMensageiro ' .. _Versao_ ou '' ,500,300);
  ig.caixa_def_borda_largura(t.jan,12);
  ig.conecte_funcao(t.jan,ig.destruido,ig.fimjanela);
  t.cv = ig.caixavertical();
  t.txt_ip_local = ig.texto('127.0.0.1:2345');//modifique para o ip e portas desejados.
  t.txt_ip_destino= ig.texto('127.0.0.1:2345');
  t.area_txt = ig.texto_area();
  t.txt_enviar=ig.texto_area(); ig.componente_def_tamanho(t.txt_enviar,400,80);
  t.bt_enviar=ig.botao' Enviar';
  ig.conecte_funcao(t.bt_enviar,ig.clique,envie_msg, t);
  ig.ad(t.jan,t.cv);
  t.bt_ligar_desligar_servidor = ig.botao_checagem(' Ligar servidor');
  ig.conecte_funcao(t.bt_ligar_desligar_servidor,ig.marcado,ligar_desligar_servidor,t);
  ad_elementos(t,ig.rotulo' Ip:porta local:      ',t.txt_ip_local,t.bt_ligar_desligar_servidor);
  ad_elementos(t,ig.rotulo' Ip:porta destino:  ',t.txt_ip_destino);
  ad_elementos(t,t.txt_enviar,t.bt_enviar);
  ig.caixa_ad(t.cv,ig.separadorhorizontal(),falso,falso,0);
  ad_elementos(t,ig.rotulo'Mensagens enviadas e recebidas:');
  t.jan_rolagem=ig.janela_rolagem();
  ig.janela_rolagem_ad(t.jan_rolagem,t.area_txt);
  ig.ad(t.cv,t.jan_rolagem);
  t.avisos = ig.rotulo'Avisos: servidor desligado!';
  ad_elementos(t,t.avisos);
  
  ig.componente_def_foco(t.bt_enviar);//coloca foco no botão enviar
  ig.componente_mostre_todos(t.jan);
  retorne t;  
fim 

funcao ligar_desligar_servidor(bt,t)
  se ig.botao_seletor_obt_ativo(bt) == verdadeiro entao //retorno verdadeiro está ligado
    ig.botao_def_rotulo(bt,' Desligar servidor');
    se nao t.servidor entao
      crie_servidor(t);//cria e inicia o servidor!
    senao
      rede.servidor_inicie(t.servidor);
    fim
  senao
    ig.botao_def_rotulo(bt,' Ligar servidor');
    rede.servidor_pare(t.servidor);//entao para o servidor.  
    ig.rotulo_def_texto(t.avisos,'Avisos: servidor desligado!');
    imprima('Avisos: servidor desligado!');  
  fim
fim

funcao ad_elementos(t,...)
  local ch = ig.caixahorizontal();
  local elementos = {...};//pega o parametro variado e transforma em tabela.
  para i,v em ipares(elementos) inicio
    ig.caixa_ad(ch,v,falso,falso,0);//coloca cada componente da tabela na caixa horizontal.
  fim
  ig.caixa_ad(t.cv,ch,falso,falso,0);
fim


funcao envie_msg(bt,t)//em prisma podemos fazer uma função dentro de outra normalmente.
    se nao t.cliente entao
      t.cliente = rede.cliente(); 
    fim
    imprima('Aguarde...');
    local destino = ig.texto_obt_texto(t.txt_ip_destino);     
    local sdest,err = obt_ip_porta(destino); //essa função analisa a url e retorna ip e porta separados em tabela
    se nao sdest entao poe(err);fim;//abandona a funcao imprimindo o erro.
  
    local conexao , erro_msg = 
    rede.cliente_conecte_com_servidor(//parametros:
        t.cliente,
        sdest.ip, //ip local
        sdest.porta//porta de conexao
    );  
    
    se nao conexao entao
       imprima( erro_msg,'\nConexao rejeitada, servidor desligado?' );
       ig.rotulo_def_texto(t.avisos,'Avisos: \n' .. erro_msg);
    senao
       local ms = ig.texto_area_obt_texto(t.txt_enviar);
       s = ig.texto_obt_texto(t.txt_ip_local) .. '\002' .. ms; 
       erro_msg = rede.escreva( conexao , s  );//mandando a mensagem.
       se erro_msg entao 
         imprima(erro_msg); 
         ig.rotulo_def_texto(t.avisos,'Avisos: \n' .. erro_msg);
       senao
         local conteudo = ig.texto_area_obt_texto(t.area_txt);  
          destino = destino .. ' em ' .. sis.data('%d/%m/%y - %H:%M');       
         ig.texto_area_def_texto(t.area_txt,'Enviado para: '.. destino ..' :\n  ' .. ms .. '\n'.. string.nconcat('_',100) .. '\n' .. conteudo);
       fim
    fim
fim
  

funcao crie_servidor(t)
   local servidor = rede.servidor();
   t.servidor = servidor;//colocando a variavel na tabela de componentes
   local url = ig.texto_obt_texto(t.txt_ip_local);
   local host = obt_ip_porta(url);
   local ret, erro_msg = rede.escute_porta(servidor,host.porta);
   se ret == falso entao
         imprima(erro_msg);
         ig.rotulo_def_texto(t.avisos,'Avisos: ' .. erro_msg);
   senao
     ig.conecte_funcao(servidor,ig.recebido, func_servidor,t);
     imprima('Servidor ativo,', url ou '');  
     ig.rotulo_def_texto(t.avisos,'Avisos: servidor ativo, ' .. url ou '');
   fim
fim

funcao ao_ler(mensagem,t)
   imprima("Cliente: " .. mensagem);
   local info = processe_msg(mensagem); 
   local conteudo = ig.texto_area_obt_texto(t.area_txt);  
   info.url = info.url .. ' em ' .. sis.data('%d/%m/%y - %H:%M');      
   ig.texto_area_def_texto(t.area_txt,'\nRecebido de: '.. info.url ..' :\n  ' .. info.msg .. ' \n' .. string.nconcat('_',100) .. '\n' .. conteudo .. '\n' );
   ig.rotulo_def_texto(t.avisos,"Avisos: conexão recebida " .. info.url ou '');
   ig.objeto_desref(t.conexao);
fim

funcao func_servidor( servidor,conexao, Gobjeto, t)
   imprima("Conexao recebida de cliente\n");
   t.conexao = ig.objeto_ref(conexao);
   rede.leia_assinc( conexao,t.BLOCO_TAM, ao_ler,t);
fim

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

175

176

177

178

179

180

181

182

183

184

185

186

/*Programa Mini messenger em Prisma + igbr + igrede

* Licença: MIT

Permission is hereby granted, free of charge, to any person obtaining a copy of this

software and associated documentation files (the "Software"), to deal in the Software

without restriction, including without limitation the rights to use, copy, modify, merge,

publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons

to whom the Software is furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in all

copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED,

INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR

PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE

FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,

ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS

IN THE SOFTWARE.

local _Versao_ = '0.2';

local _Sobre_ =

'Mini mensageiro instantâneo feito em \

Prisma-1.0.100';

local ig = inclua'igbr';

local rede = inclua'igrede';

funcao principal(arg)

local t = interface();

t.BLOCO_TAM = '1000000'; //1MB aproxim.

ig.loop(); //o mesmo que ig.fimprograma() use qual preferir.

se t.servidor entao

rede.servidor_pare(t.servidor);

fim

se t.cliente entao

ig.objeto_desref(t.cliente);//desreferencia o objeto, ou seja, limpa a memória.

fim

retorne 0;

fim

funcao obt_ip_porta(s)

local url = s:analise(':'); //os dois pontos separa o ip da porta lembra?

se nao url entao

retorne falso, "\nErro: Ip ou porta invalida";

fim;//abandona a funcao imprimindo o erro.

local ip = url[1];

local porta = url[3];//o [2] é o `:';

retorne {ip=ip,porta=porta};

fim

funcao processe_msg(s)

local dado = s:analise('\002'); //o ascii code 2 separa o cabeçalho de informação da msg.

se nao dado entao

retorne falso, "\nErro: Ip ou porta invalida";

fim;//abandona a funcao imprimindo o erro.

local url = dado[1]

local msg = dado[3];//o [2] é o `:';

retorne {url=url,msg=msg};

fim

funcao interface()

local t = {}; //criando a tabela de componentes.

t.jan = ig.janela('igMensageiro ' .. _Versao_ ou '' ,500,300);

ig.caixa_def_borda_largura(t.jan,12);

ig.conecte_funcao(t.jan,ig.destruido,ig.fimjanela);

t.cv = ig.caixavertical();

t.txt_ip_local = ig.texto('127.0.0.1:2345');//modifique para o ip e portas desejados.

t.txt_ip_destino= ig.texto('127.0.0.1:2345');

t.area_txt = ig.texto_area();

t.txt_enviar=ig.texto_area(); ig.componente_def_tamanho(t.txt_enviar,400,80);

t.bt_enviar=ig.botao' Enviar';

ig.conecte_funcao(t.bt_enviar,ig.clique,envie_msg, t);

ig.ad(t.jan,t.cv);

t.bt_ligar_desligar_servidor = ig.botao_checagem(' Ligar servidor');

ig.conecte_funcao(t.bt_ligar_desligar_servidor,ig.marcado,ligar_desligar_servidor,t);

ad_elementos(t,ig.rotulo' Ip:porta local: ',t.txt_ip_local,t.bt_ligar_desligar_servidor);

ad_elementos(t,ig.rotulo' Ip:porta destino: ',t.txt_ip_destino);

ad_elementos(t,t.txt_enviar,t.bt_enviar);

ig.caixa_ad(t.cv,ig.separadorhorizontal(),falso,falso,0);

ad_elementos(t,ig.rotulo'Mensagens enviadas e recebidas:');

t.jan_rolagem=ig.janela_rolagem();

ig.janela_rolagem_ad(t.jan_rolagem,t.area_txt);

ig.ad(t.cv,t.jan_rolagem);

t.avisos = ig.rotulo'Avisos: servidor desligado!';

ad_elementos(t,t.avisos);

ig.componente_def_foco(t.bt_enviar);//coloca foco no botão enviar

ig.componente_mostre_todos(t.jan);

retorne t;

fim

funcao ligar_desligar_servidor(bt,t)

se ig.botao_seletor_obt_ativo(bt) == verdadeiro entao //retorno verdadeiro está ligado

ig.botao_def_rotulo(bt,' Desligar servidor');

se nao t.servidor entao

crie_servidor(t);//cria e inicia o servidor!

senao

rede.servidor_inicie(t.servidor);

fim

senao

ig.botao_def_rotulo(bt,' Ligar servidor');

rede.servidor_pare(t.servidor);//entao para o servidor.

ig.rotulo_def_texto(t.avisos,'Avisos: servidor desligado!');

imprima('Avisos: servidor desligado!');

fim

funcao ad_elementos(t,...)

local ch = ig.caixahorizontal();

local elementos = {...};//pega o parametro variado e transforma em tabela.

para i,v em ipares(elementos) inicio

ig.caixa_ad(ch,v,falso,falso,0);//coloca cada componente da tabela na caixa horizontal.

fim

ig.caixa_ad(t.cv,ch,falso,falso,0);

fim

funcao envie_msg(bt,t)//em prisma podemos fazer uma função dentro de outra normalmente.

se nao t.cliente entao

t.cliente = rede.cliente();

fim

imprima('Aguarde...');

local destino = ig.texto_obt_texto(t.txt_ip_destino);

local sdest,err = obt_ip_porta(destino); //essa função analisa a url e retorna ip e porta separados em tabela

se nao sdest entao poe(err);fim;//abandona a funcao imprimindo o erro.

local conexao , erro_msg =

rede.cliente_conecte_com_servidor(//parametros:

t.cliente,

sdest.ip, //ip local

sdest.porta//porta de conexao

);

se nao conexao entao

imprima( erro_msg,'\nConexao rejeitada, servidor desligado?' );

ig.rotulo_def_texto(t.avisos,'Avisos: \n' .. erro_msg);

senao

local ms = ig.texto_area_obt_texto(t.txt_enviar);

s = ig.texto_obt_texto(t.txt_ip_local) .. '\002' .. ms;

erro_msg = rede.escreva( conexao , s );//mandando a mensagem.

se erro_msg entao

imprima(erro_msg);

ig.rotulo_def_texto(t.avisos,'Avisos: \n' .. erro_msg);

senao

local conteudo = ig.texto_area_obt_texto(t.area_txt);

destino = destino .. ' em ' .. sis.data('%d/%m/%y - %H:%M');

ig.texto_area_def_texto(t.area_txt,'Enviado para: '.. destino ..' :\n ' .. ms .. '\n'.. string.nconcat('_',100) .. '\n' .. conteudo);

fim

funcao crie_servidor(t)

local servidor = rede.servidor();

t.servidor = servidor;//colocando a variavel na tabela de componentes

local url = ig.texto_obt_texto(t.txt_ip_local);

local host = obt_ip_porta(url);

local ret, erro_msg = rede.escute_porta(servidor,host.porta);

se ret == falso entao

imprima(erro_msg);

ig.rotulo_def_texto(t.avisos,'Avisos: ' .. erro_msg);

senao

ig.conecte_funcao(servidor,ig.recebido, func_servidor,t);

imprima('Servidor ativo,', url ou '');

ig.rotulo_def_texto(t.avisos,'Avisos: servidor ativo, ' .. url ou '');

fim

funcao ao_ler(mensagem,t)

imprima("Cliente: " .. mensagem);

local info = processe_msg(mensagem);

local conteudo = ig.texto_area_obt_texto(t.area_txt);

info.url = info.url .. ' em ' .. sis.data('%d/%m/%y - %H:%M');

ig.texto_area_def_texto(t.area_txt,'\nRecebido de: '.. info.url ..' :\n ' .. info.msg .. ' \n' .. string.nconcat('_',100) .. '\n' .. conteudo .. '\n' );

ig.rotulo_def_texto(t.avisos,"Avisos: conexão recebida " .. info.url ou '');

ig.objeto_desref(t.conexao);

fim

funcao func_servidor( servidor,conexao, Gobjeto, t)

imprima("Conexao recebida de cliente\n");

t.conexao = ig.objeto_ref(conexao);

rede.leia_assinc( conexao,t.BLOCO_TAM, ao_ler,t);

fim

Bom, é isso, espero que seja útil.

Falou até mais.

Prisma

linguagem de programação em português

Mini messenger em Prisma + ig + igRede

Deixe um comentário Cancelar resposta