Subversion Repositories Kolibri OS

Rev

Rev 3792 | Rev 3794 | Go to most recent revision | Blame | Compare with Previous | Last modification | View Log | Download | RSS feed

  1. ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
  2. ;;                                                                 ;;
  3. ;; Copyright (C) KolibriOS team 2013. All rights reserved.         ;;
  4. ;; Distributed under terms of the GNU General Public License       ;;
  5. ;;                                                                 ;;
  6. ;;  ftpc.asm - FTP client for KolibriOS                            ;;
  7. ;;                                                                 ;;
  8. ;;  Written by hidnplayr@kolibrios.org                             ;;
  9. ;;                                                                 ;;
  10. ;;          GNU GENERAL PUBLIC LICENSE                             ;;
  11. ;;             Version 2, June 1991                                ;;
  12. ;;                                                                 ;;
  13. ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
  14.  
  15. format binary as ""
  16.  
  17. BUFFERSIZE              = 1024
  18.  
  19. STATUS_CONNECTING       = 0
  20. STATUS_CONNECTED        = 1
  21. STATUS_NEEDPASSWORD     = 2
  22. STATUS_LOGGED_IN        = 3
  23.  
  24. use32
  25. ; standard header
  26.         db      'MENUET01'      ; signature
  27.         dd      1               ; header version
  28.         dd      start           ; entry point
  29.         dd      i_end           ; initialized size
  30.         dd      mem+0x1000      ; required memory
  31.         dd      mem+0x1000      ; stack pointer
  32.         dd      s               ; parameters
  33.         dd      0               ; path
  34.  
  35. include '../../macros.inc'
  36. purge mov,add,sub
  37. include '../../proc32.inc'
  38. include '../../dll.inc'
  39. include '../../network.inc'
  40.  
  41. include 'usercommands.inc'
  42. include 'servercommands.inc'
  43.  
  44. ; entry point
  45. start:
  46.  
  47.         mcall   40, 0
  48. ; load libraries
  49.         stdcall dll.Load, @IMPORT
  50.         test    eax, eax
  51.         jnz     exit
  52. ; initialize console
  53.         invoke  con_start, 1
  54.         invoke  con_init, 80, 25, 80, 250, title
  55.  
  56. ; Check for parameters
  57.         cmp     byte [s], 0
  58.         jne     resolve
  59.  
  60. main:
  61.         invoke  con_cls
  62. ; Welcome user
  63.         invoke  con_write_asciiz, str1
  64.  
  65. ; write prompt
  66.         invoke  con_set_flags, 0x0a
  67.         invoke  con_write_asciiz, str2
  68. ; read string
  69.         mov     esi, s
  70.         invoke  con_gets, esi, 256
  71.         invoke  con_write_asciiz, str4  ; newline
  72.         invoke  con_set_flags, 0x07
  73. ; check for exit
  74.         test    eax, eax
  75.         jz      done
  76.         cmp     byte [esi], 10
  77.         jz      done
  78.  
  79. resolve:
  80. ; delete terminating '\n'
  81.         mov     esi, s
  82.   @@:
  83.         lodsb
  84.         cmp     al, 0x20
  85.         ja      @r
  86.         mov     byte [esi-1], 0
  87.  
  88.         invoke  con_write_asciiz, str3
  89.         invoke  con_write_asciiz, s
  90.  
  91. ; resolve name
  92.         push    esp     ; reserve stack place
  93.         invoke  getaddrinfo, s, 0, 0, esp
  94.         pop     esi
  95. ; test for error
  96.         test    eax, eax
  97.         jnz     fail
  98.  
  99. ; write results
  100.         invoke  con_write_asciiz, str8
  101. ;        mov     edi, esi
  102.  
  103. ; convert IP address to decimal notation
  104.         mov     eax, [esi+addrinfo.ai_addr]
  105.         mov     eax, [eax+sockaddr_in.sin_addr]
  106.         mov     [sockaddr1.ip], eax
  107.  
  108.         invoke  inet_ntoa, eax
  109. ; write result
  110.         invoke  con_write_asciiz, eax
  111. ; free allocated memory
  112.         invoke  freeaddrinfo, esi
  113.  
  114.         invoke  con_write_asciiz, str9
  115.         mcall   socket, AF_INET4, SOCK_STREAM, 0
  116.         cmp     eax, -1
  117.         je      socket_error
  118.         mov     [socketnum], eax
  119.  
  120.         invoke  con_write_asciiz, str11
  121.         mcall   connect, [socketnum], sockaddr1, 18
  122.         mov     [status], STATUS_CONNECTING
  123.  
  124.         invoke  con_write_asciiz, str12
  125.  
  126.         mov     [offset], 0
  127.  
  128. wait_for_servercommand:
  129.  
  130.         cmp     [offset], 0
  131.         je      .receive
  132.         mov     esi, [offset]
  133.         mov     edi, s
  134.         mov     ecx, [size]
  135.         add     ecx, esi
  136.         jmp     .byteloop
  137.  
  138. ; receive socket data
  139.   .receive:
  140.         mcall   recv, [socketnum], buffer_ptr, BUFFERSIZE, 0
  141.         inc     eax
  142.         jz      socket_error
  143.         dec     eax
  144.         jz      wait_for_servercommand
  145.  
  146.         mov     [offset], 0
  147.  
  148. ; extract commands, copy them to "s" buffer
  149.         lea     ecx, [eax + buffer_ptr]         ; ecx = end pointer
  150.         mov     esi, buffer_ptr                 ; esi = current pointer
  151.         mov     edi, s
  152.   .byteloop:
  153.         cmp     esi, ecx
  154.         jae     wait_for_servercommand
  155.         lodsb
  156.         cmp     al, 10                          ; excellent, we might have a command
  157.         je      .got_command
  158.         cmp     al, 13                          ; just ignore this byte
  159.         je      .byteloop
  160.         stosb
  161.         jmp     .byteloop
  162.   .got_command:                                 ; we have a newline check if its a command
  163.         cmp     esi, ecx
  164.         je      .no_more_data
  165.         mov     [offset], esi
  166.         sub     ecx, esi
  167.         mov     [size], ecx
  168.         jmp     .go_cmd
  169.   .no_more_data:
  170.         mov     [offset], 0
  171.   .go_cmd:
  172.         xor     al, al
  173.         stosb
  174.  
  175.         invoke  con_set_flags, 0x03             ; change color
  176.         invoke  con_write_asciiz, s             ; print servercommand
  177.         invoke  con_write_asciiz, str4          ; newline
  178.         invoke  con_set_flags, 0x07
  179.  
  180.         jmp     server_parser                   ; parse command
  181.  
  182. wait_for_usercommand:
  183.  
  184.         invoke  con_set_flags, 0x0a
  185.  
  186.         cmp     [status], STATUS_CONNECTED
  187.         je      .connected
  188.  
  189.         cmp     [status], STATUS_NEEDPASSWORD
  190.         je      .needpass
  191.  
  192. ; write prompt
  193.         invoke  con_write_asciiz, str2
  194. ; read string
  195.         mov     esi, s
  196.         invoke  con_gets, esi, 256
  197.         invoke  con_set_flags, 0x07
  198.  
  199.         cmp     dword[s], "list"
  200.         je      cmd_list
  201.  
  202.         cmp     dword[s], "help"
  203.         je      cmd_help
  204.  
  205.         cmp     dword[s], "cwd "
  206.         je      cmd_cwd
  207.  
  208.         cmp     dword[s], "retr"
  209.         je      cmd_retr
  210.  
  211. ;        cmp     dword[s], "stor"
  212. ;        je      cmd_stor
  213.  
  214.         invoke  con_write_asciiz, str_unknown
  215.         jmp     wait_for_usercommand
  216.  
  217.  
  218.   .connected:
  219.  
  220.         invoke  con_write_asciiz, str_user
  221.         mov     dword[s], "USER"
  222.         mov     byte[s+4], " "
  223.         jmp     .send
  224.  
  225.  
  226.   .needpass:
  227.  
  228.         invoke  con_write_asciiz, str_pass
  229.         mov     dword[s], "PASS"
  230.         mov     byte[s+4], " "
  231.  
  232.   .send:
  233. ; read string
  234.         mov     esi, s+5
  235.         invoke  con_gets, esi, 256
  236.  
  237.         mov     edi, s+5
  238.         mov     ecx, 256
  239.         xor     al, al
  240.         repne   scasb
  241.         lea     esi, [edi-s-1]
  242.         mcall   send, [socketnum], s, , 0
  243.  
  244.         invoke  con_write_asciiz, str4  ; newline
  245.         invoke  con_set_flags, 0x07
  246.         jmp     wait_for_servercommand
  247.  
  248.  
  249.  
  250. open_dataconnection:
  251.         cmp     [status], STATUS_LOGGED_IN
  252.         jne     .fail
  253.  
  254.         mov     dword[s], "PASV"
  255.         mov     byte[s+4], 10
  256.         mcall   send, [socketnum], s, 5, 0
  257.         ret
  258.  
  259.   .fail:
  260.         invoke  con_write_asciiz, str6
  261.         ret
  262.  
  263.  
  264.  
  265. socket_error:
  266.         invoke  con_write_asciiz, str6
  267.         jmp     fail.wait
  268.  
  269. fail:
  270.         invoke  con_write_asciiz, str5
  271.   .wait:
  272.         invoke  con_write_asciiz, str10
  273.         invoke  con_getch2
  274.         jmp     main
  275.  
  276. done:
  277.         invoke  con_exit, 1
  278.  
  279. exit:
  280.         mcall   close, [socketnum]
  281.         mcall   -1
  282.  
  283.  
  284.  
  285. ; data
  286. title   db 'FTP client',0
  287. str1    db 'FTP client for KolibriOS v0.03',10,10,'Please enter ftp server address.',10,0
  288. str2    db '> ',0
  289. str3    db 'Resolving ',0
  290. str4    db 10,0
  291. str5    db 10,'Name resolution failed.',10,0
  292. str6    db 10,'Socket error.',10,0
  293. str8    db ' (',0
  294. str9    db ')',10,0
  295. str10   db 'Push any key to continue.',0
  296. str11   db 'Connecting...',10,0
  297. str12   db 'Waiting for welcome message.',10,0
  298. str_user db "username: ",0
  299. str_pass db "password: ",0
  300. str_unknown db "unknown command",10,0
  301. str_help db "available commands:",10,10
  302.          db "help       list",10,0
  303.  
  304. str_open db "opening data socket",10,0
  305.  
  306. sockaddr1:
  307.         dw AF_INET4
  308. .port   dw 0x1500       ; 21
  309. .ip     dd 0
  310.         rb 10
  311.  
  312. sockaddr2:
  313.         dw AF_INET4
  314. .port   dw 0
  315. .ip     dd 0
  316.         rb 10
  317.  
  318.  
  319. ; import
  320. align 4
  321. @IMPORT:
  322.  
  323. library network, 'network.obj', console, 'console.obj'
  324.  
  325. import  network,        \
  326.         getaddrinfo,    'getaddrinfo',  \
  327.         freeaddrinfo,   'freeaddrinfo', \
  328.         inet_ntoa,      'inet_ntoa'
  329.  
  330. import  console,        \
  331.         con_start,      'START',        \
  332.         con_init,       'con_init',     \
  333.         con_write_asciiz,'con_write_asciiz',     \
  334.         con_exit,       'con_exit',     \
  335.         con_gets,       'con_gets',\
  336.         con_cls,        'con_cls',\
  337.         con_getch2,     'con_getch2',\
  338.         con_set_cursor_pos, 'con_set_cursor_pos',\
  339.         con_write_string, 'con_write_string',\
  340.         con_get_flags,  'con_get_flags', \
  341.         con_set_flags,  'con_set_flags'
  342.  
  343.  
  344. i_end:
  345.  
  346. active_passive  db ?
  347. socketnum       dd ?
  348. datasocket      dd ?
  349. buffer_ptr      rb BUFFERSIZE
  350. buffer_ptr2     rb BUFFERSIZE
  351. status          db ?
  352. offset          dd ?
  353. size            dd ?
  354.  
  355. s               rb 1024
  356.  
  357. mem:
  358.