]>
git.proxmox.com Git - pmg-api.git/blob - PMG/SMTP.pm
13 my($this, $sock) = @_;
15 my $class = ref($this) || $this;
17 croak
("undefined socket: ERROR") if !defined($sock);
20 $self->{sock
} = $sock;
21 $self->{lmtp
} = undef;
26 $self->reply ("220 Proxmox SMTP Ready.");
33 $self->{from
} = undef;
35 $self->{queue
} = undef;
36 delete $self->{xforward
};
37 delete $self->{status
};
41 shift-
>{sock
}->close();
45 print {shift-
>{sock
}} @_, "\r\n";;
50 my ($self, $func, $data, $maxcount) = @_;
54 my $sock = $self->{sock
};
64 $self->reply ("500 5.5.1 Error: bad syntax");
67 ($cmd, $args) = split(/\s+/, $_, 2);
70 if ($cmd eq 'helo' || $cmd eq 'ehlo' || $cmd eq 'lhlo') {
73 $self->reply ("250-PIPELINING");
74 $self->reply ("250-ENHANCEDSTATUSCODES");
75 $self->reply ("250-8BITMIME");
76 $self->reply ("250-XFORWARD NAME ADDR PROTO HELO");
77 $self->reply ("250 OK.");
78 $self->{lmtp
} = 1 if ($cmd eq 'lhlo');
80 } elsif ($cmd eq 'xforward') {
81 my @tmp = split (/\s+/, $args);
82 foreach my $attr (@tmp) {
83 my ($n, $v) = ($attr =~ /^(.*?)=(.*)$/);
84 $self->{xforward
}->{lc($n)} = $v;
86 $self->reply ("250 2.5.0 OK");
88 } elsif ($cmd eq 'noop') {
89 $self->reply ("250 2.5.0 OK");
91 } elsif ($cmd eq 'quit') {
92 $self->reply ("221 2.2.0 OK");
94 } elsif ($cmd eq 'rset') {
96 $self->reply ("250 2.5.0 OK");
98 } elsif ($cmd eq 'mail') {
99 if ($args =~ m/^from:\s*<(\S*)>/i) {
102 $self->reply ('250 2.5.0 OK');
105 $self->reply ("501 5.5.2 Syntax: MAIL FROM: <address>");
108 } elsif ($cmd eq 'rcpt') {
109 if ($args =~ m/^to:\s*<(\S+)>/i) {
110 push @{$self->{to
}} , $1;
111 $self->reply ('250 2.5.0 OK');
114 $self->reply ("501 5.5.2 Syntax: MAIL FROM: <address>");
117 } elsif ($cmd eq 'data') {
118 if ($self->save_data ()) {
119 eval { &$func ($data, $self); };
126 foreach $a (@{$self->{to
}}) {
127 if ($self->{queue
}->{status
}->{$a} eq 'delivered') {
128 $self->reply ("250 2.5.0 OK ($self->{queue}->{logid})");
129 } elsif ($self->{queue
}->{status
}->{$a} eq 'blocked') {
130 $self->reply ("250 2.7.0 BLOCKED ($self->{queue}->{logid})");
131 } elsif ($self->{queue
}->{status
}->{$a} eq 'error') {
132 my $code = $self->{queue
}->{status_code
}->{$a};
133 my $resp = substr($code, 0, 1);
134 my $mess = $self->{queue
}->{status_message
}->{$a};
135 $self->reply ("$code $resp.0.0 $mess");
137 $self->reply ("451 4.4.0 detected undelivered mail to <$a>");
143 foreach $a (@{$self->{to
}}) {
144 if (!($self->{queue
}->{status
}->{$a} eq 'delivered' ||
145 $self->{queue
}->{status
}->{$a} eq 'blocked')) {
150 $self->reply ("250 2.5.0 OK ($self->{queue}->{logid})");
152 $self->reply ("451 4.4.0 detected undelivered mail");
160 last if $count >= $maxcount;
161 last if $data->{errors
}; # abort if we find errors
165 $self->reply ("500 5.5.1 Error: unknown command");
168 $self->{sock
}->close;
176 if(!defined($self->{from
})) {
177 $self->reply ("503 5.5.1 Tell me who you are.");
181 if(!defined($self->{to
})) {
182 $self->reply ("503 5.5.1 Tell me who to send it.");
186 $self->reply ("354 End data with <CR><LF>.<CR><LF>");
188 my $sock = $self->{sock
};
193 $queue = PMG
::MailQueue-
>new ($self->{from
}, $self->{to
});
202 # RFC 2821 compliance.
207 print {$queue->{fh
}} $_;
208 $queue->{bytes
} += length ($_);
211 $queue->{fh
}->flush ();
213 $self->{queue
} = $queue;
218 $self->reply ("451 4.5.0 Local delivery failed: $@");
221 if(!defined($done)) {
222 $self->reply ("451 4.5.0 Local delivery failed: unfinished data");