[projects/pld-ftp-admin.git] / bin / pfa-from-incoming

#!/usr/bin/env python3
# vi: encoding=utf-8 ts=8 sts=4 sw=4 et

from __future__ import print_function

import sys, os, stat, time, re
sys.path.insert(0, os.environ['HOME']+'/pld-ftp-admin/modules')
from config import incoming_dir, default_to, ftp_archs
from config import value as cval
import config
from common import noarchcachedir, tmpdir, fileexists
from baseftptree import BaseFtpTree, BasePkg
from ftptree import FtpTree, Pkg
import ftpio

os.umask(0o022)

def rm(file):
    os.remove(file)

def mv(src, dst):
    os.rename(src, dst + '/' + src.split('/')[-1])

# duplicate code in ftptree.py
def is_debuginfo(nvr):
    """
    returns true if NVR is debuginfo package and separate debuginfo is enabled
    """
    if not config.separate_debuginfo:
        return False
    pkg = nvr.split('-')[:-2]
    return pkg[-1] == 'debuginfo'

def findfiles(dir):
    def filterinfos(x):
        if x[-11:] == '.uploadinfo':
            return True
        else:
            return False
    return filter(filterinfos, os.listdir(dir))

def getcontent(file):
    f = open(file, 'r')
    content = f.read()
    f.close()
    if not content[-5:] == '\nEND\n':
        return None
    else:
        return content[:-4]

def send_noarch_msg(files_differ, reqs_differ, pkg, rpmfile, arch):
    req_email=pkg.build[pkg.lastbid].requester_email
    req_bid=pkg.lastbid
    cc_list=[]
    if 'logs_list' in cval:
        cc_list.append(cval['logs_list'])
    m_subject="Noarch error: %s files differ among builders" % rpmfile
    bids=pkg.build.keys()
    if len(bids)>1:
        for bid in bids:
            newcc=pkg.build[bid].requester_email
            if req_email!=newcc and newcc not in cc_list:
                cc_list.append(newcc)

    msg="From: %s\nTo: %s\n" % (cval['from_field'], req_email)
    if cc_list:
        msg=msg+"Cc: %s\n" % ", ".join(cc_list)
    msg=msg+"""X-PLD-Builder: %s
References: <%s@pld.src.builder>
In-Reply-To: <%s@pld.src.builder>
Subject: %s

""" % (cval['xpldbuilder'], req_bid, req_bid, m_subject)

    sm = os.popen("/usr/sbin/sendmail -t", "w")

    sm.write(msg)

    if files_differ:
        f=open("%s/files.diff" % tmpdir, 'r')
        sm.write("Difference between %s (currently in %s) and %s FILES\n" %
              (pkg.noarch_arch[rpmfile], repr(ftptree), arch)),
        for line in f.readlines(True)[2:]:
            sm.write(line)
        f.close()

    sm.write('\n')

    if reqs_differ:
        f=open("%s/reqs.diff" % tmpdir, 'r')
        sm.write("Difference between %s (currently in %s) and %s REQS\n" %
              (pkg.noarch_arch[rpmfile], repr(ftptree), arch)),
        for line in f.readlines(True)[2:]:
            sm.write(line)
        f.close()

    sm.close()

def move_noarch(f, arch, rpmfile, dstpkg):
    if rpmfile in dstpkg.noarch_arch:
        os.system("LC_ALL=C rpm -qlp %s | LC_ALL=C sort > %s/files.new" %
                  (incoming_dir + arch + '/' + rpmfile, tmpdir))
        os.system("rpm -qRp %s | LC_ALL=C sort | LC_ALL=C uniq > %s/reqs.new" %
                  (incoming_dir + arch + '/' + rpmfile, tmpdir))

        files_differ = False
        reqs_differ = False

        if os.system("diff -u %s/%s.filelist %s/files.new > %s/files.diff" %
                     (noarchcachedir, rpmfile, tmpdir, tmpdir)):
            files_differ = True
        if os.system("diff -u %s/%s.reqlist %s/reqs.new > %s/reqs.diff" %
                     (noarchcachedir, rpmfile, tmpdir, tmpdir)):
            reqs_differ = True

        if files_differ or reqs_differ:
            send_noarch_msg(files_differ, reqs_differ, dstpkg, rpmfile, arch)

        rm(incoming_dir + arch + '/' + rpmfile)
    else:
        os.system("LC_ALL=C rpm -qlp %s | LC_ALL=C sort > %s/%s.filelist" %
                  (incoming_dir + arch + '/' + rpmfile, noarchcachedir, rpmfile))
        os.system("rpm -qRp %s | LC_ALL=C sort | LC_ALL=C uniq > %s/%s.reqlist" %
                  (incoming_dir + arch + '/' + rpmfile, noarchcachedir, rpmfile))
        if arch not in dstpkg.files:
            f.write("file:noarch:%s\ninfo:noarch_arch:%s:%s\n" % (rpmfile, rpmfile, arch))
        mv(incoming_dir + arch + '/' + rpmfile, default_to + 'noarch/RPMS')

def send_vr_msg(snvr, anvr, pkg, arch):
    req_email=pkg.build[pkg.lastbid].requester_email
    req_bid=pkg.lastbid
    cc_list=[]
    if 'logs_list' in cval:
        cc_list.append(cval['logs_list'])
    m_subject="NVR error: %s version or relese differ among subpackages" % snvr[0]
    bids=pkg.build.keys()
    if len(bids)>1:
        for bid in bids:
            newcc=pkg.build[bid].requester_email
            if req_email!=newcc and newcc not in cc_list:
                cc_list.append(newcc)

    msg="From: %s\nTo: %s\n" % (cval['from_field'], req_email)
    if cc_list:
        msg=msg+"Cc: %s\n" % ", ".join(cc_list)
    msg=msg+"""X-PLD-Builder: %s
References: <%s@pld.src.builder>
In-Reply-To: <%s@pld.src.builder>
Subject: %s

""" % (cval['xpldbuilder'], req_bid, req_bid, m_subject)

    sm = os.popen("/usr/sbin/sendmail -t", "w")

    sm.write(msg)

    sm.write("Difference between %s SRPM (currently in %s) and %s RPM NVR:\n\n" %
          (snvr[0], repr(ftptree), arch)),
    sm.write("Expected (%s):\nV: %s\nR: %s\n\n" % snvr)
    sm.write("RPM:\nN: %s\nV: %s\nR: %s\n" % anvr)
    sm.write('\n')

    sm.close()

# main()
try:
    ftpio.connect('from-incoming-pid-%s' % os.getpid())
except:
    print("Can't get ftpiod connection")
    sys.exit(1)

ftptree = BaseFtpTree(cval['default_to'])

if not ftpio.lock(cval['default_to']):
    print("Can't get lock: %s" % cval['default_to'])
    sys.exit(1)

moved_anything = False

for uploadinfo in findfiles(incoming_dir + 'SRPMS'):
    content = getcontent(incoming_dir + 'SRPMS/' + uploadinfo)
    if not content:
        continue # Uploading not finished

    pkg = BasePkg(uploadinfo[:-19], content = content)
    srpm = pkg.files['SRPMS'][0]

    if not os.path.exists(incoming_dir + 'SRPMS/' + srpm):
        ftpio.log("%s file missing; skipping move until next round" % (srpm))
        continue

    if ftptree.has_key(repr(pkg)):
        ftpio.log("%s already present in %s; removing older files" % (srpm, ftptree))
        rm(default_to + 'SRPMS/RPMS/' + srpm)
        f = open(default_to + 'SRPMS/.metadata/' + srpm+'.info', 'a')
        bid = pkg.build.keys()[0]
        build = pkg.build[bid]
        f.write("info:build:%s:requester:%s\ninfo:build:%s:requester_email:%s\n"
                 % (bid, build.requester, bid, build.requester_email))
        f.close()
    else:
        f = open(default_to + 'SRPMS/.metadata/' + srpm + '.info', 'w')
        f.write(content)
        f.close()

    mv(incoming_dir + 'SRPMS/' + srpm, default_to + 'SRPMS/RPMS')
    rm(incoming_dir + 'SRPMS/' + uploadinfo)

for arch in ftp_archs:
    for uploadinfo in findfiles(incoming_dir + arch):
        content = getcontent(incoming_dir + arch + '/' + uploadinfo)
        if not content:
            ftpio.log("%s not finished uploading" % uploadinfo)
            continue # Uploading not finished

        srcpkg = BasePkg(uploadinfo[:-19], content = content)
        srpm = srcpkg.files['SRPMS'][0]

        if not ftptree.has_key(repr(srcpkg)):
            continue # We require the src.rpm to be present

        renvr = re.compile(r'(.*)-(.*)-(.*)\.[^.]*\.rpm')
        srcnvr = renvr.match(srpm).groups()

        rpmfile_missing = [f for f in srcpkg.files['ARCH'] if not os.path.exists(incoming_dir + arch + '/'+f)]
        if len(rpmfile_missing):
            for filem in rpmfile_missing:
                ftpio.log("%s file missing; skipping move until next round" % (filem))
            continue

        dstpkg = BasePkg(repr(srcpkg), ftptree)

        if arch in dstpkg.files:
            ftpio.log("files from %s for arch %s already present in %s; removing older files" % (repr(srcpkg), arch, ftptree))
            for rpmfile in dstpkg.files[arch]:
                if is_debuginfo(rpmfile):
                    dstfile = default_to + arch + '/debuginfo'
                else:
                    dstfile = default_to + arch + '/RPMS'
                try:
                    rm(dstfile + '/' + rpmfile)
                except OSError as e:
                    l = "Removing %s problem: %s" % (dstfile + '/' + rpmfile, e)
                    ftpio.log(l)
                    print(l)

        f = open(default_to + 'SRPMS/.metadata/' + srpm + '.info', 'a')
        for rpmfile in srcpkg.files['ARCH']:
            moved_anything = True

# Too much noise, too little use
#            archnvr = renvr.match(rpmfile).groups()
#            if srcnvr[1] != archnvr[1] or srcnvr[2] != archnvr[2]:
#                send_vr_msg(srcnvr, archnvr, dstpkg, arch)

            if rpmfile[-11:] == '.noarch.rpm' and config.separate_noarch:
                move_noarch(f, arch, rpmfile, dstpkg)
            else:
                if arch not in dstpkg.files:
                    f.write("file:%s:%s\n" % (arch, rpmfile))
                srcfile = incoming_dir + arch + '/' + rpmfile

                if is_debuginfo(rpmfile):
                    dstfile = default_to + arch + '/debuginfo'
                else:
                    dstfile = default_to + arch + '/RPMS'

                try:
                    mv(srcfile, dstfile)
                except OSError as e:
                    l = "Moving %s to %s problem: %s" % (srcfile, dstfile, e)
                    ftpio.log(l)
                    print(l)
        f.close()

        rm(incoming_dir + arch + '/' + uploadinfo)

ftpio.unlock(cval['default_to'])

if moved_anything:
    os.system("%s/pld-ftp-admin/bin/pfa-genindex --quiet test > /dev/null" % (os.getenv("HOME")))
Commit	Line	Data
a1e62e44	1	#!/usr/bin/env python3
38b2b764 MM	2	# vi: encoding=utf-8 ts=8 sts=4 sw=4 et
38b2b764 MM	3
2ec96333 JR	4	from __future__ import print_function
2ec96333 JR	5
c77db9e7	6	import sys, os, stat, time, re
38b2b764 MM	7	sys.path.insert(0, os.environ['HOME']+'/pld-ftp-admin/modules')
38b2b764 MM	8	from config import incoming_dir, default_to, ftp_archs
8e089d4f	9	from config import value as cval
38b2b764	10	import config
acd976ec	11	from common import noarchcachedir, tmpdir, fileexists
bb2cb325	12	from baseftptree import BaseFtpTree, BasePkg
8e089d4f	13	from ftptree import FtpTree, Pkg
0a108b7f	14	import ftpio
38b2b764	15
ce26983c	16	os.umask(0o022)
fc574b00	17
38b2b764	18	def rm(file):
18c8e935	19	os.remove(file)
38b2b764 MM	20
38b2b764 MM	21	def mv(src, dst):
8911f226	22	os.rename(src, dst + '/' + src.split('/')[-1])
38b2b764	23
54ff0049 ER	24	# duplicate code in ftptree.py
	25	def is_debuginfo(nvr):
	26	"""
	27	returns true if NVR is debuginfo package and separate debuginfo is enabled
	28	"""
	29	if not config.separate_debuginfo:
	30	return False
	31	pkg = nvr.split('-')[:-2]
	32	return pkg[-1] == 'debuginfo'
	33
38b2b764 MM	34	def findfiles(dir):
38b2b764 MM	35	def filterinfos(x):
8911f226	36	if x[-11:] == '.uploadinfo':
76dc40c3	37	return True
38b2b764 MM	38	else:
	39	return False
	40	return filter(filterinfos, os.listdir(dir))
	41
38b2b764	42	def getcontent(file):
8911f226 ER	43	f = open(file, 'r')
8911f226 ER	44	content = f.read()
38b2b764	45	f.close()
8911f226	46	if not content[-5:] == '\nEND\n':
38b2b764 MM	47	return None
	48	else:
	49	return content[:-4]
	50
8e089d4f	51	def send_noarch_msg(files_differ, reqs_differ, pkg, rpmfile, arch):
200470c5 MM	52	req_email=pkg.build[pkg.lastbid].requester_email
	53	req_bid=pkg.lastbid
	54	cc_list=[]
0fa16f20 MM	55	if 'logs_list' in cval:
0fa16f20 MM	56	cc_list.append(cval['logs_list'])
8e089d4f	57	m_subject="Noarch error: %s files differ among builders" % rpmfile
200470c5 MM	58	bids=pkg.build.keys()
	59	if len(bids)>1:
	60	for bid in bids:
	61	newcc=pkg.build[bid].requester_email
	62	if req_email!=newcc and newcc not in cc_list:
	63	cc_list.append(newcc)
	64
	65	msg="From: %s\nTo: %s\n" % (cval['from_field'], req_email)
	66	if cc_list:
	67	msg=msg+"Cc: %s\n" % ", ".join(cc_list)
	68	msg=msg+"""X-PLD-Builder: %s
	69	References: <%s@pld.src.builder>
	70	In-Reply-To: <%s@pld.src.builder>
	71	Subject: %s
	72
	73	""" % (cval['xpldbuilder'], req_bid, req_bid, m_subject)
	74
	75	sm = os.popen("/usr/sbin/sendmail -t", "w")
8e089d4f	76
200470c5 MM	77	sm.write(msg)
	78
	79	if files_differ:
	80	f=open("%s/files.diff" % tmpdir, 'r')
	81	sm.write("Difference between %s (currently in %s) and %s FILES\n" %
4794304a	82	(pkg.noarch_arch[rpmfile], repr(ftptree), arch)),
200470c5 MM	83	for line in f.readlines(True)[2:]:
	84	sm.write(line)
	85	f.close()
	86
	87	sm.write('\n')
	88
	89	if reqs_differ:
	90	f=open("%s/reqs.diff" % tmpdir, 'r')
	91	sm.write("Difference between %s (currently in %s) and %s REQS\n" %
4794304a	92	(pkg.noarch_arch[rpmfile], repr(ftptree), arch)),
200470c5 MM	93	for line in f.readlines(True)[2:]:
	94	sm.write(line)
	95	f.close()
	96
	97	sm.close()
	98
8e089d4f	99	def move_noarch(f, arch, rpmfile, dstpkg):
b353ff36	100	if rpmfile in dstpkg.noarch_arch:
a999d554	101	os.system("LC_ALL=C rpm -qlp %s \| LC_ALL=C sort > %s/files.new" %
8e089d4f	102	(incoming_dir + arch + '/' + rpmfile, tmpdir))
ca2e224a	103	os.system("rpm -qRp %s \| LC_ALL=C sort \| LC_ALL=C uniq > %s/reqs.new" %
8e089d4f	104	(incoming_dir + arch + '/' + rpmfile, tmpdir))
bb2cb325	105
8911f226 ER	106	files_differ = False
8911f226 ER	107	reqs_differ = False
bb2cb325 MM	108
bb2cb325 MM	109	if os.system("diff -u %s/%s.filelist %s/files.new > %s/files.diff" %
8e089d4f	110	(noarchcachedir, rpmfile, tmpdir, tmpdir)):
8911f226	111	files_differ = True
bb2cb325	112	if os.system("diff -u %s/%s.reqlist %s/reqs.new > %s/reqs.diff" %
8e089d4f	113	(noarchcachedir, rpmfile, tmpdir, tmpdir)):
8911f226	114	reqs_differ = True
bb2cb325 MM	115
bb2cb325 MM	116	if files_differ or reqs_differ:
8e089d4f	117	send_noarch_msg(files_differ, reqs_differ, dstpkg, rpmfile, arch)
bb2cb325	118
8e089d4f	119	rm(incoming_dir + arch + '/' + rpmfile)
bb2cb325	120	else:
ca2e224a	121	os.system("LC_ALL=C rpm -qlp %s \| LC_ALL=C sort > %s/%s.filelist" %
8e089d4f	122	(incoming_dir + arch + '/' + rpmfile, noarchcachedir, rpmfile))
ca2e224a	123	os.system("rpm -qRp %s \| LC_ALL=C sort \| LC_ALL=C uniq > %s/%s.reqlist" %
8e089d4f	124	(incoming_dir + arch + '/' + rpmfile, noarchcachedir, rpmfile))
b353ff36	125	if arch not in dstpkg.files:
c0d14f9d	126	f.write("file:noarch:%s\ninfo:noarch_arch:%s:%s\n" % (rpmfile, rpmfile, arch))
8e089d4f	127	mv(incoming_dir + arch + '/' + rpmfile, default_to + 'noarch/RPMS')
38b2b764	128
c77db9e7 JR	129	def send_vr_msg(snvr, anvr, pkg, arch):
	130	req_email=pkg.build[pkg.lastbid].requester_email
	131	req_bid=pkg.lastbid
	132	cc_list=[]
	133	if 'logs_list' in cval:
	134	cc_list.append(cval['logs_list'])
	135	m_subject="NVR error: %s version or relese differ among subpackages" % snvr[0]
	136	bids=pkg.build.keys()
	137	if len(bids)>1:
	138	for bid in bids:
	139	newcc=pkg.build[bid].requester_email
	140	if req_email!=newcc and newcc not in cc_list:
	141	cc_list.append(newcc)
	142
	143	msg="From: %s\nTo: %s\n" % (cval['from_field'], req_email)
	144	if cc_list:
	145	msg=msg+"Cc: %s\n" % ", ".join(cc_list)
	146	msg=msg+"""X-PLD-Builder: %s
	147	References: <%s@pld.src.builder>
	148	In-Reply-To: <%s@pld.src.builder>
	149	Subject: %s
	150
	151	""" % (cval['xpldbuilder'], req_bid, req_bid, m_subject)
	152
	153	sm = os.popen("/usr/sbin/sendmail -t", "w")
	154
	155	sm.write(msg)
	156
	157	sm.write("Difference between %s SRPM (currently in %s) and %s RPM NVR:\n\n" %
4794304a	158	(snvr[0], repr(ftptree), arch)),
c82d0ed4 JR	159	sm.write("Expected (%s):\nV: %s\nR: %s\n\n" % snvr)
c82d0ed4 JR	160	sm.write("RPM:\nN: %s\nV: %s\nR: %s\n" % anvr)
c77db9e7 JR	161	sm.write('\n')
	162
	163	sm.close()
	164
e4b21e2b ER	165	# main()
	166	try:
	167	ftpio.connect('from-incoming-pid-%s' % os.getpid())
	168	except:
2ec96333	169	print("Can't get ftpiod connection")
65017da5	170	sys.exit(1)
e4b21e2b ER	171
	172	ftptree = BaseFtpTree(cval['default_to'])
	173
	174	if not ftpio.lock(cval['default_to']):
2ec96333	175	print("Can't get lock: %s" % cval['default_to'])
65017da5	176	sys.exit(1)
e4b21e2b	177
7c2f5e4c AM	178	moved_anything = False
7c2f5e4c AM	179
e4b21e2b ER	180	for uploadinfo in findfiles(incoming_dir + 'SRPMS'):
	181	content = getcontent(incoming_dir + 'SRPMS/' + uploadinfo)
	182	if not content:
	183	continue # Uploading not finished
	184
	185	pkg = BasePkg(uploadinfo[:-19], content = content)
	186	srpm = pkg.files['SRPMS'][0]
	187
46d96a92 AM	188	if not os.path.exists(incoming_dir + 'SRPMS/' + srpm):
	189	ftpio.log("%s file missing; skipping move until next round" % (srpm))
	190	continue
	191
7aec4c36	192	if ftptree.has_key(repr(pkg)):
99b125ec JR	193	ftpio.log("%s already present in %s; removing older files" % (srpm, ftptree))
99b125ec JR	194	rm(default_to + 'SRPMS/RPMS/' + srpm)
e4b21e2b ER	195	f = open(default_to + 'SRPMS/.metadata/' + srpm+'.info', 'a')
	196	bid = pkg.build.keys()[0]
	197	build = pkg.build[bid]
	198	f.write("info:build:%s:requester:%s\ninfo:build:%s:requester_email:%s\n"
	199	% (bid, build.requester, bid, build.requester_email))
	200	f.close()
	201	else:
e4b21e2b ER	202	f = open(default_to + 'SRPMS/.metadata/' + srpm + '.info', 'w')
	203	f.write(content)
	204	f.close()
	205
99b125ec	206	mv(incoming_dir + 'SRPMS/' + srpm, default_to + 'SRPMS/RPMS')
e4b21e2b ER	207	rm(incoming_dir + 'SRPMS/' + uploadinfo)
e4b21e2b ER	208
38b2b764	209	for arch in ftp_archs:
8e089d4f	210	for uploadinfo in findfiles(incoming_dir + arch):
8911f226	211	content = getcontent(incoming_dir + arch + '/' + uploadinfo)
38b2b764	212	if not content:
2abd3b77	213	ftpio.log("%s not finished uploading" % uploadinfo)
38b2b764 MM	214	continue # Uploading not finished
38b2b764 MM	215
8911f226 ER	216	srcpkg = BasePkg(uploadinfo[:-19], content = content)
8911f226 ER	217	srpm = srcpkg.files['SRPMS'][0]
38b2b764	218
7aec4c36	219	if not ftptree.has_key(repr(srcpkg)):
38b2b764 MM	220	continue # We require the src.rpm to be present
38b2b764 MM	221
c77db9e7 JR	222	renvr = re.compile(r'(.)-(.)-(.)\.[^.]\.rpm')
	223	srcnvr = renvr.match(srpm).groups()
	224
46d96a92 AM	225	rpmfile_missing = [f for f in srcpkg.files['ARCH'] if not os.path.exists(incoming_dir + arch + '/'+f)]
	226	if len(rpmfile_missing):
	227	for filem in rpmfile_missing:
	228	ftpio.log("%s file missing; skipping move until next round" % (filem))
	229	continue
	230
4794304a	231	dstpkg = BasePkg(repr(srcpkg), ftptree)
38b2b764	232
b353ff36	233	if arch in dstpkg.files:
4794304a	234	ftpio.log("files from %s for arch %s already present in %s; removing older files" % (repr(srcpkg), arch, ftptree))
99b125ec JR	235	for rpmfile in dstpkg.files[arch]:
	236	if is_debuginfo(rpmfile):
	237	dstfile = default_to + arch + '/debuginfo'
	238	else:
	239	dstfile = default_to + arch + '/RPMS'
2eb653d6	240	try:
99b125ec	241	rm(dstfile + '/' + rpmfile)
9c170c61	242	except OSError as e:
99b125ec	243	l = "Removing %s problem: %s" % (dstfile + '/' + rpmfile, e)
2eb653d6	244	ftpio.log(l)
2ec96333	245	print(l)
38b2b764	246
8911f226	247	f = open(default_to + 'SRPMS/.metadata/' + srpm + '.info', 'a')
8e089d4f	248	for rpmfile in srcpkg.files['ARCH']:
7c2f5e4c	249	moved_anything = True
c77db9e7	250
164d8d15 JR	251	# Too much noise, too little use
	252	# archnvr = renvr.match(rpmfile).groups()
	253	# if srcnvr[1] != archnvr[1] or srcnvr[2] != archnvr[2]:
	254	# send_vr_msg(srcnvr, archnvr, dstpkg, arch)
c77db9e7	255
8e089d4f ER	256	if rpmfile[-11:] == '.noarch.rpm' and config.separate_noarch:
8e089d4f ER	257	move_noarch(f, arch, rpmfile, dstpkg)
bb2cb325	258	else:
b353ff36	259	if arch not in dstpkg.files:
c0d14f9d	260	f.write("file:%s:%s\n" % (arch, rpmfile))
8e089d4f	261	srcfile = incoming_dir + arch + '/' + rpmfile
8911f226	262
8e089d4f	263	if is_debuginfo(rpmfile):
54ff0049 ER	264	dstfile = default_to + arch + '/debuginfo'
	265	else:
	266	dstfile = default_to + arch + '/RPMS'
8911f226	267
631d11b9	268	try:
8911f226	269	mv(srcfile, dstfile)
9c170c61	270	except OSError as e:
8911f226	271	l = "Moving %s to %s problem: %s" % (srcfile, dstfile, e)
631d11b9	272	ftpio.log(l)
2ec96333	273	print(l)
38b2b764 MM	274	f.close()
38b2b764 MM	275
8911f226	276	rm(incoming_dir + arch + '/' + uploadinfo)
38b2b764	277
0a108b7f	278	ftpio.unlock(cval['default_to'])
7c2f5e4c AM	279
7c2f5e4c AM	280	if moved_anything:
a34f0e55	281	os.system("%s/pld-ftp-admin/bin/pfa-genindex --quiet test > /dev/null" % (os.getenv("HOME")))