%% %% %CopyrightBegin% %% %% Copyright Ericsson AB 2005-2010. All Rights Reserved. %% %% The contents of this file are subject to the Erlang Public License, %% Version 1.1, (the "License"); you may not use this file except in %% compliance with the License. You should have received a copy of the %% Erlang Public License along with this software. If not, it can be %% retrieved online at http://www.erlang.org/. %% %% Software distributed under the License is distributed on an "AS IS" %% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See %% the License for the specific language governing rights and limitations %% under the License. %% %% %CopyrightEnd% %% %% %%% Description: SSH file handling -module(ssh_file). -include("ssh.hrl"). -include("PKCS-1.hrl"). -include("DSS.hrl"). -export([public_host_dsa_key/2,private_host_dsa_key/2, public_host_rsa_key/2,private_host_rsa_key/2, public_host_key/2,private_host_key/2, lookup_host_key/3, add_host_key/3, % del_host_key/2, lookup_user_key/3, ssh_dir/2, file_name/3]). -export([private_identity_key/2]). %% , public_identity_key/2, %% identity_keys/2]). -export([encode_public_key/1, decode_public_key_v2/2]). -import(lists, [reverse/1, append/1]). -define(DBG_PATHS, true). %% API public_host_dsa_key(Type, Opts) -> File = file_name(Type, "ssh_host_dsa_key.pub", Opts), read_public_key_v2(File, "ssh-dss"). private_host_dsa_key(Type, Opts) -> File = file_name(Type, "ssh_host_dsa_key", Opts), read_private_key_v2(File, "ssh-dss"). public_host_rsa_key(Type, Opts) -> File = file_name(Type, "ssh_host_rsa_key.pub", Opts), read_public_key_v2(File, "ssh-rsa"). private_host_rsa_key(Type, Opts) -> File = file_name(Type, "ssh_host_rsa_key", Opts), read_private_key_v2(File, "ssh-rsa"). public_host_key(Type, Opts) -> File = file_name(Type, "ssh_host_key", Opts), case read_private_key_v1(File,public) of {error, enoent} -> read_public_key_v1(File++".pub"); Result -> Result end. private_host_key(Type, Opts) -> File = file_name(Type, "ssh_host_key", Opts), read_private_key_v1(File,private). %% in: "host" out: "host,1.2.3.4. add_ip(Host) -> case inet:getaddr(Host, inet) of {ok, Addr} -> case ssh_connection:encode_ip(Addr) of false -> Host; IPString -> Host ++ "," ++ IPString end; _ -> Host end. replace_localhost("localhost") -> {ok, Hostname} = inet:gethostname(), Hostname; replace_localhost(Host) -> Host. %% lookup_host_key %% return {ok, Key(s)} or {error, not_found} %% lookup_host_key(Host, Alg, Opts) -> Host1 = replace_localhost(Host), do_lookup_host_key(Host1, Alg, Opts). do_lookup_host_key(Host, Alg, Opts) -> case file:open(file_name(user, "known_hosts", Opts), [read]) of {ok, Fd} -> Res = lookup_host_key_fd(Fd, Host, Alg), file:close(Fd), Res; {error, enoent} -> {error, not_found}; Error -> Error end. add_host_key(Host, Key, Opts) -> Host1 = add_ip(replace_localhost(Host)), case file:open(file_name(user, "known_hosts", Opts),[write,append]) of {ok, Fd} -> Res = add_key_fd(Fd, Host1, Key), file:close(Fd), Res; Error -> Error end. %% del_host_key(Host, Opts) -> %% Host1 = replace_localhost(Host), %% case file:open(file_name(user, "known_hosts", Opts),[write,read]) of %% {ok, Fd} -> %% Res = del_key_fd(Fd, Host1), %% file:close(Fd), %% Res; %% Error -> %% Error %% end. identity_key_filename("ssh-dss") -> "id_dsa"; identity_key_filename("ssh-rsa") -> "id_rsa". private_identity_key(Alg, Opts) -> Path = file_name(user, identity_key_filename(Alg), Opts), read_private_key_v2(Path, Alg). read_public_key_v2(File, Type) -> case file:read_file(File) of {ok,Bin} -> List = binary_to_list(Bin), case lists:prefix(Type, List) of true -> List1 = lists:nthtail(length(Type), List), K_S = ssh_bits:b64_decode(List1), decode_public_key_v2(K_S, Type); false -> {error, bad_format} end; Error -> Error end. decode_public_key_v2(K_S, "ssh-rsa") -> case ssh_bits:decode(K_S,[string,mpint,mpint]) of ["ssh-rsa", E, N] -> {ok, #ssh_key { type = rsa, public = {N,E}, comment=""}}; _ -> {error, bad_format} end; decode_public_key_v2(K_S, "ssh-dss") -> case ssh_bits:decode(K_S,[string,mpint,mpint,mpint,mpint]) of ["ssh-dss",P,Q,G,Y] -> {ok,#ssh_key { type = dsa, public = {P,Q,G,Y} }}; _A -> {error, bad_format} end; decode_public_key_v2(_, _) -> {error, bad_format}. read_public_key_v1(File) -> case file:read_file(File) of {ok,Bin} -> List = binary_to_list(Bin), case io_lib:fread("~d ~d ~d ~s", List) of {ok,[_Sz,E,N,Comment],_} -> {ok,#ssh_key { type = rsa, public ={N,E}, comment = Comment }}; _Error -> {error, bad_format} end; Error -> Error end. %% pem_type("ssh-dss") -> "DSA"; %% pem_type("ssh-rsa") -> "RSA". read_private_key_v2(File, Type) -> case catch (public_key:pem_to_der(File)) of {ok, [{_, Bin, not_encrypted}]} -> decode_private_key_v2(Bin, Type); Error -> %% Note we do not handle password encrypted keys at the moment {error, Error} end. %% case file:read_file(File) of %% {ok,Bin} -> %% case read_pem(binary_to_list(Bin), pem_type(Type)) of %% {ok,Bin1} -> %% decode_private_key_v2(Bin1, Type); %% Error -> %% Error %% end; %% Error -> %% Error %% end. decode_private_key_v2(Private,"ssh-rsa") -> case 'PKCS-1':decode( 'RSAPrivateKey', Private) of {ok,RSA} -> %% FIXME Check for two-prime version {ok, #ssh_key { type = rsa, public = {RSA#'RSAPrivateKey'.modulus, RSA#'RSAPrivateKey'.publicExponent}, private = {RSA#'RSAPrivateKey'.modulus, RSA#'RSAPrivateKey'.privateExponent} }}; Error -> Error end; decode_private_key_v2(Private, "ssh-dss") -> case 'DSS':decode('DSAPrivateKey', Private) of {ok,DSA} -> %% FIXME Check for two-prime version {ok, #ssh_key { type = dsa, public = {DSA#'DSAPrivateKey'.p, DSA#'DSAPrivateKey'.q, DSA#'DSAPrivateKey'.g, DSA#'DSAPrivateKey'.y}, private= {DSA#'DSAPrivateKey'.p, DSA#'DSAPrivateKey'.q, DSA#'DSAPrivateKey'.g, DSA#'DSAPrivateKey'.x} }}; _ -> {error,bad_format} end. %% SSH1 private key format %% <<"SSH PRIVATE KEY FILE FORMATE 1.1\n" 0:8 %% CipherNum:8, Reserved:32, %% NSz/uint32, N/bignum, E/bignum, Comment/string, %% %% [ R0:8 R1:8 R0:8 R1:8, D/bignum, IQMP/bignum, Q/bignum, P/bignum, Pad(8)]>> %% %% where [ ] is encrypted using des3 (ssh1 version) and %% a posssibly empty pass phrase using md5(passphase) as key %% read_private_key_v1(File, Type) -> case file:read_file(File) of {ok,<<"SSH PRIVATE KEY FILE FORMAT 1.1\n",0, CipherNum,_Resereved:32,Bin/binary>>} -> decode_private_key_v1(Bin, CipherNum,Type); {ok,_} -> {error, bad_format}; Error -> Error end. decode_private_key_v1(Bin, CipherNum, Type) -> case ssh_bits:decode(Bin,0,[uint32, bignum, bignum, string]) of {Offset,[_NSz,N,E,Comment]} -> if Type == public -> {ok,#ssh_key { type=rsa, public={N,E}, comment=Comment}}; Type == private -> <<_:Offset/binary, Encrypted/binary>> = Bin, case ssh_bits:decode(decrypt1(Encrypted, CipherNum),0, [uint32, bignum, bignum, bignum, bignum,{pad,8}]) of {_,[_,D,IQMP,Q,P]} -> {ok,#ssh_key { type=rsa, public={N,E}, private={D,IQMP,Q,P}, comment=Comment}}; _ -> {error,bad_format} end end; _ -> {error,bad_format} end. decrypt1(Bin, CipherNum) -> decrypt1(Bin, CipherNum,""). decrypt1(Bin, CipherNum, Phrase) -> if CipherNum == ?SSH_CIPHER_NONE; Phrase == "" -> Bin; CipherNum == ?SSH_CIPHER_3DES -> <<K1:8/binary, K2:8/binary>> = erlang:md5(Phrase), K3 = K1, IV = <<0,0,0,0,0,0,0,0>>, Bin1 = crypto:des_cbc_decrypt(K3,IV,Bin), Bin2 = crypto:des_cbc_encrypt(K2,IV,Bin1), crypto:des_cbc_decrypt(K1,IV,Bin2) end. %% encrypt1(Bin, CipherNum) -> %% encrypt1(Bin, CipherNum,""). %% encrypt1(Bin, CipherNum, Phrase) -> %% if CipherNum == ?SSH_CIPHER_NONE; Phrase == "" -> %% Bin; %% CipherNum == ?SSH_CIPHER_3DES -> %% <<K1:8/binary, K2:8/binary>> = erlang:md5(Phrase), %% K3 = K1, %% IV = <<0,0,0,0,0,0,0,0>>, %% Bin1 = crypto:des_cbc_encrypt(K1,IV,Bin), %% Bin2 = crypto:des_cbc_decrypt(K2,IV,Bin1), %% crypto:des_cbc_encrypt(K3,IV,Bin2) %% end. lookup_host_key_fd(Fd, Host, Alg) -> case io:get_line(Fd, '') of eof -> {error, not_found}; Line -> case string:tokens(Line, " ") of [HostList, Alg, KeyData] -> %% io:format(" ~p lookup_host_key_fd: HostList ~p Alg ~p KeyData ~p\n", %% [Host, HostList, Alg, KeyData]), case lists:member(Host, string:tokens(HostList, ",")) of true -> decode_public_key_v2(ssh_bits:b64_decode(KeyData), Alg); false -> lookup_host_key_fd(Fd, Host, Alg) end; _ -> lookup_host_key_fd(Fd, Host, Alg) end end. %% del_key_fd(Fd, Host) -> %% del_key_fd(Fd, Host, 0, 0). %% del_key_fd(Fd, Host, ReadPos0, WritePos0) -> %% case io:get_line(Fd, '') of %% eof -> %% if ReadPos0 == WritePos0 -> %% ok; %% true -> %% file:truncate(Fd) %% end; %% Line -> %% {ok,ReadPos1} = file:position(Fd, cur), %% case string:tokens(Line, " ") of %% [HostList, _Type, _KeyData] -> %% case lists:member(Host, string:tokens(HostList, ",")) of %% true -> %% del_key_fd(Fd, Host, ReadPos1, WritePos0); %% false -> %% if ReadPos0 == WritePos0 -> %% del_key_fd(Fd, Host, ReadPos1, ReadPos1); %% true -> %% file:position(Fd, WritePos0), %% file:write(Fd, Line), %% {ok,WritePos1} = file:position(Fd,cur), %% del_key_fd(Fd, Host, ReadPos1, WritePos1) %% end %% end; %% _ -> %% if ReadPos0 == WritePos0 -> %% del_key_fd(Fd, Host, ReadPos1, ReadPos1); %% true -> %% file:position(Fd, WritePos0), %% file:write(Fd, Line), %% {ok,WritePos1} = file:position(Fd,cur), %% del_key_fd(Fd, Host, ReadPos1, WritePos1) %% end %% end %% end. add_key_fd(Fd, Host, Key) -> case Key#ssh_key.type of rsa -> {N,E} = Key#ssh_key.public, DK = ssh_bits:b64_encode( ssh_bits:encode(["ssh-rsa",E,N], [string,mpint,mpint])), file:write(Fd, [Host, " ssh-rsa ", DK, "\n"]); dsa -> {P,Q,G,Y} = Key#ssh_key.public, DK = ssh_bits:b64_encode( ssh_bits:encode(["ssh-dss",P,Q,G,Y], [string,mpint,mpint,mpint,mpint])), file:write(Fd, [Host, " ssh-dss ", DK, "\n"]) end. %% read_pem(Cs, Type) -> %% case read_line(Cs) of %% {"-----BEGIN "++Rest,Cs1} -> %% case string:tokens(Rest, " ") of %% [Type, "PRIVATE", "KEY-----"] -> %% read_pem64(Cs1, [], Type); %% _ -> %% {error, bad_format} %% end; %% {"",Cs1} when Cs1 =/= "" -> %% read_pem(Cs1,Type); %% {_,""} -> %% {error, bad_format} %% end. %% read_pem64(Cs, Acc, Type) -> %% case read_line(Cs) of %% {"-----END "++Rest,_Cs1} -> %% case string:tokens(Rest, " ") of %% [Type, "PRIVATE", "KEY-----"] -> %% {ok,ssh_bits:b64_decode(append(reverse(Acc)))}; %% Toks -> %% error_logger:format("ssh: TOKENS=~p\n", [Toks]), %% {error, bad_format} %% end; %% {B64, Cs1} when Cs1 =/= "" -> %% read_pem64(Cs1, [B64|Acc], Type); %% _What -> %% {error, bad_format} %% end. %% read_line(Cs) -> read_line(Cs,[]). %% read_line([$\r,$\n|T], Acc) -> {reverse(Acc), T}; %% read_line([$\n|T], Acc) -> {reverse(Acc), T}; %% read_line([C|T], Acc) -> read_line(T,[C|Acc]); %% read_line([], Acc) -> {reverse(Acc),[]}. lookup_user_key(User, Alg, Opts) -> SshDir = ssh_dir({remoteuser,User}, Opts), case lookup_user_key_f(User, SshDir, Alg, "authorized_keys", Opts) of {ok, Key} -> {ok, Key}; _ -> lookup_user_key_f(User, SshDir, Alg, "authorized_keys2", Opts) end. lookup_user_key_f(_User, [], _Alg, _F, _Opts) -> {error, nouserdir}; lookup_user_key_f(_User, nouserdir, _Alg, _F, _Opts) -> {error, nouserdir}; lookup_user_key_f(_User, Dir, Alg, F, _Opts) -> FileName = filename:join(Dir, F), case file:open(FileName, [read]) of {ok, Fd} -> Res = lookup_user_key_fd(Fd, Alg), file:close(Fd), Res; {error, Reason} -> {error, {{openerr, Reason}, {file, FileName}}} end. lookup_user_key_fd(Fd, Alg) -> case io:get_line(Fd, '') of eof -> {error, not_found}; Line -> case string:tokens(Line, " ") of [Alg, KeyData, _] -> %% io:format("lookup_user_key_fd: HostList ~p Alg ~p KeyData ~p\n", %% [HostList, Alg, KeyData]), decode_public_key_v2(ssh_bits:b64_decode(KeyData), Alg); _Other -> %%?dbg(false, "key_fd Other: ~w ~w\n", [Alg, _Other]), lookup_user_key_fd(Fd, Alg) end end. encode_public_key(#ssh_key{type = rsa, public = {N, E}}) -> ssh_bits:encode(["ssh-rsa",E,N], [string,mpint,mpint]); encode_public_key(#ssh_key{type = dsa, public = {P,Q,G,Y}}) -> ssh_bits:encode(["ssh-dss",P,Q,G,Y], [string,mpint,mpint,mpint,mpint]). %% %% Utils %% %% server use this to find individual keys for %% an individual user when user tries to login %% with publickey ssh_dir({remoteuser, User}, Opts) -> case proplists:get_value(user_dir_fun, Opts) of undefined -> case proplists:get_value(user_dir, Opts) of undefined -> default_user_dir(); Dir -> Dir end; FUN -> FUN(User) end; %% client use this to find client ssh keys ssh_dir(user, Opts) -> case proplists:get_value(user_dir, Opts, false) of false -> default_user_dir(); D -> D end; %% server use this to find server host keys ssh_dir(system, Opts) -> proplists:get_value(system_dir, Opts, "/etc/ssh"). file_name(Type, Name, Opts) -> FN = filename:join(ssh_dir(Type, Opts), Name), %%?dbg(?DBG_PATHS, "file_name: ~p\n", [FN]), FN. default_user_dir()-> {ok,[[Home|_]]} = init:get_argument(home), filename:join(Home, ".ssh").