4 #include <QCryptographicHash>
5 #include <QHostAddress>
18 #include "libmythbase/mythversion.h"
20 #include "libmythbase/version.h"
37 qRegisterMetaType<V2ConnectionInfo*>(
"V2ConnectionInfo");
38 qRegisterMetaType<V2VersionInfo*>(
"V2VersionInfo");
39 qRegisterMetaType<V2DatabaseInfo*>(
"V2DatabaseInfo");
40 qRegisterMetaType<V2WOLInfo*>(
"V2WOLInfo");
41 qRegisterMetaType<V2StorageGroupDirList*>(
"V2StorageGroupDirList");
42 qRegisterMetaType<V2StorageGroupDir*>(
"V2StorageGroupDir");
43 qRegisterMetaType<V2TimeZoneInfo*>(
"V2TimeZoneInfo");
44 qRegisterMetaType<V2LogMessage*>(
"V2LogMessage");
45 qRegisterMetaType<V2LogMessageList*>(
"V2LogMessageList");
46 qRegisterMetaType<V2LabelValue*>(
"V2LabelValue");
47 qRegisterMetaType<V2Frontend*>(
"V2Frontend");
48 qRegisterMetaType<V2FrontendList*>(
"V2FrontendList");
49 qRegisterMetaType<V2SettingList*>(
"V2SettingList");
50 qRegisterMetaType<V2BackendInfo*>(
"V2BackendInfo");
51 qRegisterMetaType<V2EnvInfo*>(
"V2EnvInfo");
52 qRegisterMetaType<V2LogInfo*>(
"V2LogInfo");
53 qRegisterMetaType<V2BuildInfo*>(
"V2BuildInfo");
70 if ( sSecurityPin.isEmpty() )
71 throw( QString(
"No Security Pin assigned. Run mythtv-setup to set one." ));
74 if ((sSecurityPin !=
"0000" ) && ( sPin != sSecurityPin ))
75 throw( QString(
"Not Authorized" ));
87 if ((params.
m_dbHostName.compare(
"localhost",Qt::CaseInsensitive)==0
90 && !sServerIP.isEmpty())
101 if (addr.setAddress(dbHostName))
103 addr.setScopeId(QString());
104 dbHostName = addr.toString();
115 pDatabase->setHost ( dbHostName );
117 pDatabase->setPort ( params.
m_dbPort );
120 pDatabase->setName ( params.
m_dbName );
121 pDatabase->setType ( params.
m_dbType );
130 pVersion->setVersion ( MYTH_SOURCE_VERSION );
131 pVersion->setBranch ( MYTH_SOURCE_PATH );
132 pVersion->setProtocol ( MYTH_PROTO_VERSION );
133 pVersion->setBinary ( MYTH_BINARY_VERSION );
134 pVersion->setSchema ( MYTH_DATABASE_VERSION );
148 bool bResult =
false;
150 QString db(
"mythconverg");
160 throw( QString(
"Database test failed. Not saving database connection information." ));
187 throw( QString(
"No MythCoreContext in GetHostName." ));
201 throw( QString(
"Database not open while trying to load list of hosts" ));
204 "SELECT DISTINCTROW hostname "
206 "WHERE (not isNull( hostname ))");
212 throw( QString(
"Database Error executing query." ));
222 oList.append( query.
value(0).toString() );
236 throw( QString(
"Database not open while trying to load settings"));
238 query.
prepare(
"SELECT DISTINCTROW value FROM settings;" );
244 throw( QString(
"Database Error executing query." ));
251 QStringList oResults;
256 oResults.append( query.
value(0).toString() );
267 QDir directory(DirName);
268 return directory.entryList(QDir::AllDirs|QDir::NoDotAndDotDot, QDir::Name);
276 const QString &sHostName )
281 throw( QString(
"Database not open while trying to list "
282 "Storage Group Dirs"));
284 if (!sGroupName.isEmpty() && !sHostName.isEmpty())
286 query.
prepare(
"SELECT id, groupname, hostname, dirname "
288 "WHERE groupname = :GROUP AND hostname = :HOST "
289 "ORDER BY groupname, hostname, dirname" );
293 else if (!sHostName.isEmpty())
295 query.
prepare(
"SELECT id, groupname, hostname, dirname "
297 "WHERE hostname = :HOST "
298 "ORDER BY groupname, hostname, dirname" );
301 else if (!sGroupName.isEmpty())
303 query.
prepare(
"SELECT id, groupname, hostname, dirname "
305 "WHERE groupname = :GROUP "
306 "ORDER BY groupname, hostname, dirname" );
311 query.
prepare(
"SELECT id, groupname, hostname, dirname "
313 "ORDER BY groupname, hostname, dirname" );
320 throw( QString(
"Database Error executing query." ));
332 QFileInfo fi(query.
value(3).toString());
339 pStorageGroupDir->setId ( query.
value(0).toInt() );
340 pStorageGroupDir->setGroupName ( query.
value(1).toString() );
341 pStorageGroupDir->setHostName ( query.
value(2).toString() );
342 pStorageGroupDir->setDirName ( query.
value(3).toString() );
343 pStorageGroupDir->setDirRead ( fi.isReadable() );
344 pStorageGroupDir->setDirWrite ( fi.isWritable() );
345 pStorageGroupDir->setKiBFree ( free );
356 const QString &sDirName,
357 const QString &sHostName )
362 throw( QString(
"Database not open while trying to add Storage Group "
365 if (sGroupName.isEmpty())
366 throw ( QString(
"Storage Group Required" ));
368 if (sDirName.isEmpty())
369 throw ( QString(
"Directory Name Required" ));
371 if (sHostName.isEmpty())
372 throw ( QString(
"HostName Required" ));
374 query.
prepare(
"SELECT COUNT(*) "
376 "WHERE groupname = :GROUPNAME "
377 "AND dirname = :DIRNAME "
378 "AND hostname = :HOSTNAME;");
379 query.
bindValue(
":GROUPNAME", sGroupName );
381 query.
bindValue(
":HOSTNAME" , sHostName );
386 throw( QString(
"Database Error executing query." ));
391 if (query.
value(0).toInt() > 0)
395 query.
prepare(
"INSERT storagegroup "
396 "( groupname, dirname, hostname ) "
398 "( :GROUPNAME, :DIRNAME, :HOSTNAME );");
399 query.
bindValue(
":GROUPNAME", sGroupName );
401 query.
bindValue(
":HOSTNAME" , sHostName );
407 throw( QString(
"Database Error executing query." ));
418 const QString &sDirName,
419 const QString &sHostName )
424 throw( QString(
"Database not open while trying to remove Storage "
427 if (sGroupName.isEmpty())
428 throw ( QString(
"Storage Group Required" ));
430 if (sDirName.isEmpty())
431 throw ( QString(
"Directory Name Required" ));
433 if (sHostName.isEmpty())
434 throw ( QString(
"HostName Required" ));
438 "WHERE groupname = :GROUPNAME "
439 "AND dirname = :DIRNAME "
440 "AND hostname = :HOSTNAME;");
441 query.
bindValue(
":GROUPNAME", sGroupName );
443 query.
bindValue(
":HOSTNAME" , sHostName );
448 throw( QString(
"Database Error executing query." ));
512 if (!dateTime.isValid())
513 throw QString(
"Unable to parse DateTime" );
523 const QString &Application,
526 const QString &Thread,
527 const QString &Filename,
529 const QString &Function,
530 const QDateTime &FromTime,
531 const QDateTime &ToTime,
532 const QString &Level,
533 const QString &MsgContains )
540 QString sql =
"SELECT DISTINCT host FROM logging ORDER BY host ASC";
541 if (!query.
exec(sql))
545 throw( QString(
"Database Error executing query." ));
550 QString availableHostName = query.
value(0).toString();
551 pLabelValue->setValue ( availableHostName );
552 pLabelValue->setActive ( availableHostName == HostName );
553 pLabelValue->setSelected( availableHostName == HostName );
556 sql =
"SELECT DISTINCT application FROM logging ORDER BY application ASC";
557 if (!query.
exec(sql))
561 throw( QString(
"Database Error executing query." ));
566 QString availableApplication = query.
value(0).toString();
567 pLabelValue->setValue ( availableApplication );
568 pLabelValue->setActive ( availableApplication == Application );
569 pLabelValue->setSelected( availableApplication == Application );
572 if (!HostName.isEmpty() && !Application.isEmpty())
575 sql =
"SELECT host, application, pid, tid, thread, filename, "
576 " line, function, msgtime, level, message "
578 " WHERE host = COALESCE(:HOSTNAME, host) "
579 " AND application = COALESCE(:APPLICATION, application) "
580 " AND pid = COALESCE(:PID, pid) "
581 " AND tid = COALESCE(:TID, tid) "
582 " AND thread = COALESCE(:THREAD, thread) "
583 " AND filename = COALESCE(:FILENAME, filename) "
584 " AND line = COALESCE(:LINE, line) "
585 " AND function = COALESCE(:FUNCTION, function) "
586 " AND msgtime >= COALESCE(:FROMTIME, msgtime) "
587 " AND msgtime <= COALESCE(:TOTIME, msgtime) "
588 " AND level <= COALESCE(:LEVEL, level) "
590 if (!MsgContains.isEmpty())
592 sql.append(
" AND message LIKE :MSGCONTAINS ");
594 sql.append(
" ORDER BY msgtime ASC;");
596 #if QT_VERSION < QT_VERSION_CHECK(6,0,0)
597 QVariant ullNull = QVariant(QVariant::ULongLong);
599 QVariant ullNull = QVariant(QMetaType(QMetaType::ULongLong));
603 query.
bindValue(
":HOSTNAME", (HostName.isEmpty()) ? QString() : HostName);
604 query.
bindValue(
":APPLICATION", (Application.isEmpty()) ? QString() :
607 query.
bindValue(
":TID", ( TID == 0 ) ? ullNull : (qint64)TID);
608 query.
bindValue(
":THREAD", (Thread.isEmpty()) ? QString() : Thread);
609 query.
bindValue(
":FILENAME", (Filename.isEmpty()) ? QString() : Filename);
610 query.
bindValue(
":LINE", ( Line == 0 ) ? ullNull : (qint64)Line);
611 query.
bindValue(
":FUNCTION", (Function.isEmpty()) ? QString() : Function);
612 query.
bindValue(
":FROMTIME", (FromTime.isValid()) ? FromTime : QDateTime());
613 query.
bindValue(
":TOTIME", (ToTime.isValid()) ? ToTime : QDateTime());
614 query.
bindValue(
":LEVEL", (Level.isEmpty()) ? ullNull :
617 if (!MsgContains.isEmpty())
619 query.
bindValue(
":MSGCONTAINS",
"%" + MsgContains +
"%" );
626 throw( QString(
"Database Error executing query." ));
633 pLogMessage->setHostName( query.
value(0).toString() );
634 pLogMessage->setApplication( query.
value(1).toString() );
635 pLogMessage->setPID( query.
value(2).toInt() );
636 pLogMessage->setTID( query.
value(3).toInt() );
637 pLogMessage->setThread( query.
value(4).toString() );
638 pLogMessage->setFilename( query.
value(5).toString() );
639 pLogMessage->setLine( query.
value(6).toInt() );
640 pLogMessage->setFunction( query.
value(7).toString() );
643 (LogLevel_t)query.
value(9).toInt()) );
644 pLogMessage->setMessage( query.
value(10).toString() );
670 const QString &sDefault )
673 throw( QString(
"Missing or empty Key (settings.value)") );
675 if (sHostName ==
"_GLOBAL_")
679 query.
prepare(
"SELECT data FROM settings "
680 "WHERE value = :VALUE "
681 "AND (hostname IS NULL)" );
688 throw( QString(
"Database Error executing query." ));
691 return query.
next() ? query.
value(0).toString() : sDefault;
696 if (sHostName.isEmpty())
713 throw( QString(
"Database not open while trying to load settings for host: %1")
719 pList->setHostName ( sHostName );
725 if (sHostName.isEmpty())
727 query.
prepare(
"SELECT value, data FROM settings "
728 "WHERE (hostname IS NULL)" );
732 query.
prepare(
"SELECT value, data FROM settings "
733 "WHERE (hostname = :HOSTNAME)" );
735 query.
bindValue(
":HOSTNAME", sHostName );
745 throw( QString(
"Database Error executing query." ));
749 pList->Settings().insert( query.
value(0).toString(), query.
value(1) );
760 const QString &sValue )
762 QString hostName = sHostName;
764 if (hostName ==
"_GLOBAL_")
772 throw ( QString(
"Key Required" ));
782 QString hostName = sHostName;
784 if (hostName ==
"_GLOBAL_")
792 throw ( QString(
"Key Required" ));
801 const QString &sUserName,
802 const QString &sPassword,
803 const QString &sDBName,
806 bool bResult =
false;
808 QString db(
"mythconverg");
811 if (!sDBName.isEmpty())
817 bResult =
TestDatabase(sHostName, sUserName, sPassword, db, port);
827 const QString &sAddress,
831 bool bResult =
false;
833 if (sMessage.isEmpty())
836 if (Timeout < 0 || Timeout > 999)
840 "<mythmessage version=\"1\">\n"
841 " <text>" + sMessage +
"</text>\n"
842 " <timeout>" + QString::number(Timeout) +
"</timeout>\n"
845 QHostAddress address = QHostAddress::Broadcast;
846 unsigned short port = 6948;
848 if (!sAddress.isEmpty())
849 address.setAddress(sAddress);
854 auto *sock =
new QUdpSocket();
855 QByteArray utf8 = xmlMessage.toUtf8();
856 int size = utf8.length();
858 if (sock->writeDatagram(utf8.constData(), size, address, port) < 0)
860 LOG(VB_GENERAL, LOG_ERR,
861 QString(
"Failed to send UDP/XML packet (Message: %1 "
862 "Address: %2 Port: %3")
863 .arg(sMessage, sAddress, QString::number(port)));
867 LOG(VB_GENERAL, LOG_DEBUG,
868 QString(
"UDP/XML packet sent! (Message: %1 Address: %2 Port: %3")
870 address.toString().toLocal8Bit(),
871 QString::number(port)));
882 const QString &sMessage,
883 const QString &sOrigin,
884 const QString &sDescription,
885 const QString &sImage,
886 const QString &sExtra,
887 const QString &sProgressText,
893 const QString &sAddress,
896 bool bResult =
false;
898 if (sMessage.isEmpty())
901 if (Timeout < 0 || Timeout > 999)
905 "<mythnotification version=\"1\">\n"
906 " <text>" + sMessage +
"</text>\n"
907 " <origin>" + (sOrigin.isNull() ? tr(
"MythServices") : sOrigin) +
"</origin>\n"
908 " <description>" + sDescription +
"</description>\n"
909 " <timeout>" + QString::number(Timeout) +
"</timeout>\n"
910 " <image>" + sImage +
"</image>\n"
911 " <extra>" + sExtra +
"</extra>\n"
912 " <progress_text>" + sProgressText +
"</progress_text>\n"
913 " <progress>" + QString::number(fProgress) +
"</progress>\n"
914 " <fullscreen>" + (bFullscreen ?
"true" :
"false") +
"</fullscreen>\n"
915 " <visibility>" + QString::number(Visibility) +
"</visibility>\n"
916 " <priority>" + QString::number(
Priority) +
"</priority>\n"
917 " <type>" + (bError ?
"error" : Type) +
"</type>\n"
918 "</mythnotification>";
920 QHostAddress address = QHostAddress::Broadcast;
921 unsigned short port = 6948;
923 if (!sAddress.isEmpty())
924 address.setAddress(sAddress);
929 auto *sock =
new QUdpSocket();
930 QByteArray utf8 = xmlMessage.toUtf8();
931 int size = utf8.length();
933 if (sock->writeDatagram(utf8.constData(), size, address, port) < 0)
935 LOG(VB_GENERAL, LOG_ERR,
936 QString(
"Failed to send UDP/XML packet (Notification: %1 "
937 "Address: %2 Port: %3")
938 .arg(sMessage, sAddress, QString::number(port)));
942 LOG(VB_GENERAL, LOG_DEBUG,
943 QString(
"UDP/XML packet sent! (Notification: %1 Address: %2 Port: %3")
945 address.toString().toLocal8Bit(), QString::number(port)));
960 bool bResult =
false;
966 LOG(VB_GENERAL, LOG_NOTICE,
"Performing API invoked DB Backup.");
972 LOG(VB_GENERAL, LOG_NOTICE,
"Database backup succeeded.");
976 LOG(VB_GENERAL, LOG_ERR,
"Database backup failed.");
987 LOG(VB_GENERAL, LOG_NOTICE,
"Performing API invoked DB Check.");
992 LOG(VB_GENERAL, LOG_NOTICE,
"Database check complete.");
994 LOG(VB_GENERAL, LOG_ERR,
"Database check failed.");
1002 if (scheduler ==
nullptr)
1005 LOG(VB_GENERAL, LOG_NOTICE,
"Shutdown delayed 5 minutes for external application.");
1016 LOG(VB_GENERAL, LOG_NOTICE,
"Profile Submission...");
1018 bool bResult =
profile.SubmitProfile();
1020 LOG(VB_GENERAL, LOG_NOTICE,
"Profile Submitted.");
1032 LOG(VB_GENERAL, LOG_NOTICE,
"Profile Deletion...");
1034 bool bResult =
profile.DeleteProfile();
1036 LOG(VB_GENERAL, LOG_NOTICE,
"Profile Deleted.");
1047 QString sProfileURL;
1051 sProfileURL =
profile.GetProfileURL();
1052 LOG(VB_GENERAL, LOG_NOTICE, QString(
"ProfileURL: %1").arg(sProfileURL));
1063 QString sProfileUpdate;
1068 tUpdated =
profile.GetLastUpdate();
1069 sProfileUpdate = tUpdated.toString(
1072 return sProfileUpdate;
1081 QString sProfileText;
1086 return sProfileText;
1105 pBuild->setVersion ( MYTH_SOURCE_VERSION );
1106 pBuild->setLibX264 ( CONFIG_LIBX264 );
1107 pBuild->setLibDNS_SD ( CONFIG_LIBDNS_SD );
1108 pEnv->setLANG ( qEnvironmentVariable(
"LANG") );
1109 pEnv->setLCALL ( qEnvironmentVariable(
"LC_ALL") );
1110 pEnv->setLCCTYPE ( qEnvironmentVariable(
"LC_CTYPE") );
1111 pEnv->setHOME ( qEnvironmentVariable(
"HOME") );
1113 pEnv->setUSER ( qEnvironmentVariable(
"USER",
1114 qEnvironmentVariable(
"USERNAME")) );
1115 pEnv->setMYTHCONFDIR ( qEnvironmentVariable(
"MYTHCONFDIR") );
1119 pLog->setLogArgs ( logArgs );
1134 const QString &sUserName,
1135 const QString &sPassword,
1136 const QString &sNewPassword,
1137 const QString &sAdminPassword )
1142 if (sAction ==
"Add")
1144 else if (sAction ==
"Remove")
1146 else if (sAction ==
"ChangePassword")
1150 LOG(VB_GENERAL, LOG_ERR, QString(
"Action must be Add, Remove or "
1151 "ChangePassword, not '%1'")
1157 sPassword, sNewPassword,
1166 const QString &sAdminPassword )
1168 LOG(VB_GENERAL, LOG_WARNING, QString(
"ManageUrlProtection is deprecated."
1169 "Protection unavailable in API V2."));
1173 LOG(VB_GENERAL, LOG_ERR, QString(
"Backend has no '%1' user!")
1181 LOG(VB_GENERAL, LOG_ERR, QString(
"Incorrect password for user: %1")
1186 QStringList serviceList = sServices.split(
",");
1188 serviceList.removeDuplicates();
1190 QStringList protectedURLs;
1192 if (serviceList.size() == 1 && serviceList.first() ==
"All")
1195 protectedURLs <<
'/' + service;
1197 else if (serviceList.size() == 1 && serviceList.first() ==
"None")
1199 protectedURLs <<
"Unprotected";
1203 for (
const QString& service : serviceList)
1206 protectedURLs <<
'/' + service;
1208 LOG(VB_GENERAL, LOG_ERR, QString(
"Invalid service name: '%1'")
1213 if (protectedURLs.isEmpty())
1215 LOG(VB_GENERAL, LOG_ERR,
"No valid Services were found");
1220 protectedURLs.join(
';'),
"");